StepTelemetry
Read onlyYes
FinalYes
Methods
- load() : void
- operator() : Generator<string|int, Rows>
- One span per operator per run: wall time from the first pull of $batches to its last batch, or to an early stop.
- transform() : Rows
Methods
load()
public
load(Loader $loader, Rows $rows, FlowContext $context) : void
Parameters
- $loader : Loader
- $rows : Rows
- $context : FlowContext
operator()
One span per operator per run: wall time from the first pull of $batches to its last batch, or to an early stop.
public
operator(class-string $class, Generator<string|int, Rows> $batches, FlowContext $context) : Generator<string|int, Rows>
With transformations untraced, $batches itself.
Parameters
- $class : class-string
-
the processor or join yielding $batches
- $batches : Generator<string|int, Rows>
- $context : FlowContext
Return values
Generator<string|int, Rows>transform()
public
transform(Transformer $transformer, Rows $rows, FlowContext $context) : Rows
Parameters
- $transformer : Transformer
- $rows : Rows
- $context : FlowContext