Launcher extends Sniffs
Methods
- read() : Launch|null
- Decides before the first batch whether launching the head of $plan's chain pays; null when it does not and the executor reads $source. Otherwise the launch: its rows are identical to the launched steps run over the source's own scan of $criteria, with the source's rows and the workers' peaks counted into $counts.
- sniff() : null|array<int, Sample>
- Whole-unit sniffs for everyRow(): units 0..$units-1, every unit sniffed with budget -1, Samples in unit order.
Methods
read()
Decides before the first batch whether launching the head of $plan's chain pays; null when it does not and the executor reads $source. Otherwise the launch: its rows are identical to the launched steps run over the source's own scan of $criteria, with the source's rows and the workers' peaks counted into $counts.
public
read(PhysicalPlan $plan, SplittableExtractor $source, Criteria $criteria, FlowContext $context[, RunCounts|null $counts = null ]) : Launch|null
Parameters
- $plan : PhysicalPlan
- $source : SplittableExtractor
- $criteria : Criteria
- $context : FlowContext
- $counts : RunCounts|null = null
Return values
Launch|nullsniff()
Whole-unit sniffs for everyRow(): units 0..$units-1, every unit sniffed with budget -1, Samples in unit order.
public
sniff(Sniffer $sniffer, int<0, max> $units) : null|array<int, Sample>
Parameters
- $sniffer : Sniffer
- $units : int<0, max>
Return values
null|array<int, Sample> —null: the units are sniffed in this process