Flow PHP

Config

Read onlyYes

FinalYes

Properties

$cache : CacheConfig
$grouping : BucketingConfig
$join : HashJoinConfig
$repartition : BucketingConfig
$sort : MemorySortConfig|ExternalSortConfig
$telemetry : TelemetryConfig

Methods

__construct() : mixed
analyze() : Analyze|null
backend() : Backend
clock() : ClockInterface
executor() : Executor
id() : string
launcher() : Launcher|null: Runs every read of a SplittableExtractor in this run: one launcher serves the whole run. Null: every read runs in this process.
name() : string
optimizer() : Optimizer
planner() : Planner
randomValueGenerator() : RandomValueGenerator
serializer() : Serializer
telemetryAttributes() : Rule>>, telemetry: array{trace_loading: bool, trace_transformations: bool, collect_metrics: bool}, spill: array{sort: class-string, group_by: class-string, join: class-string}}: The settings a run logs when it starts.
version() : string

$cache


        public
            CacheConfig
    $cache

$grouping


        public
            BucketingConfig
    $grouping

$join


        public
            HashJoinConfig
    $join

$repartition


        public
            BucketingConfig
    $repartition

$sort


        public
            MemorySortConfig|ExternalSortConfig
    $sort

$telemetry


        public
            TelemetryConfig
    $telemetry

__construct()


    public
                    __construct(string $id, string $name, string $version, Serializer $serializer, ClockInterface $clock, Optimizer $optimizer, Executor $executor, CacheConfig $cache, MemorySortConfig|ExternalSortConfig $sort, Analyze|null $analyze, TelemetryConfig $telemetry, BucketingConfig $grouping, HashJoinConfig $join, BucketingConfig $repartition, Backend $backend[, RandomValueGenerator $randomValueGenerator = new NativePHPRandomValueGenerator() ][, Launcher|null $launcher = null ]) : mixed

Parameters

$id : string
$name : string
$version : string
$serializer : Serializer
$clock : ClockInterface
$optimizer : Optimizer
$executor : Executor
$cache : CacheConfig
$sort : MemorySortConfig|ExternalSortConfig
$analyze : Analyze|null
$telemetry : TelemetryConfig
$grouping : BucketingConfig
$join : HashJoinConfig
$repartition : BucketingConfig
$backend : Backend
$randomValueGenerator : RandomValueGenerator = new NativePHPRandomValueGenerator()
$launcher : Launcher|null = null

analyze()


    public
                    analyze() : Analyze|null

Return values

Analyze|null

backend()


    public
                    backend() : Backend

Return values

Backend

clock()


    public
                    clock() : ClockInterface

Return values

ClockInterface

executor()


    public
                    executor() : Executor

Return values

Executor

id()


    public
                    id() : string

Return values

string

launcher()

Runs every read of a SplittableExtractor in this run: one launcher serves the whole run. Null: every read runs in this process.


    public
                    launcher() : Launcher|null

Return values

Launcher|null

name()


    public
                    name() : string

Return values

string

optimizer()


    public
                    optimizer() : Optimizer

Return values

Optimizer

planner()


    public
                    planner() : Planner

Return values

Planner

randomValueGenerator()


    public
                    randomValueGenerator() : RandomValueGenerator

Return values

RandomValueGenerator

serializer()


    public
                    serializer() : Serializer

Return values

Serializer

telemetryAttributes()

The settings a run logs when it starts.


    public
                    telemetryAttributes() : Rule>>, telemetry: array{trace_loading: bool, trace_transformations: bool, collect_metrics: bool}, spill: array{sort: class-string, group_by: class-string, join: class-string}}

Return values

Rule>>, telemetry: array{trace_loading: bool, trace_transformations: bool, collect_metrics: bool}, spill: array{sort: class-string, group_by: class-string, join: class-string}}

version()


    public
                    version() : string

Return values

string