BucketAggregation
Read onlyYes
FinalYes
Methods
- __construct() : mixed
- aggregate() : Generator<string|int, Rows>
- Reached only when the plan could not bind, so the shape comes from the first batch that carries rows.
- aggregateBound() : Generator<string|int, Rows>
Methods
__construct()
public
__construct([int<1, max> $batchSize = 1000 ]) : mixed
Parameters
- $batchSize : int<1, max> = 1000
aggregate()
Reached only when the plan could not bind, so the shape comes from the first batch that carries rows.
public
aggregate(Generator<string|int, Rows> $rows, FlowContext $context, GroupBy $groupBy) : Generator<string|int, Rows>
Parameters
- $rows : Generator<string|int, Rows>
- $context : FlowContext
- $groupBy : GroupBy
Return values
Generator<string|int, Rows>aggregateBound()
public
aggregateBound(Generator<string|int, Rows> $rows, FlowContext $context, GroupBy $groupBy, GroupByShape $shape) : Generator<string|int, Rows>
Parameters
- $rows : Generator<string|int, Rows>
- $context : FlowContext
- $groupBy : GroupBy
- $shape : GroupByShape