AggregatedGroups
FinalYes
Methods
- __construct() : mixed
- absorbEarlier() : void
- accumulate() : void
- count() : int
- flush() : Generator<string|int, Rows>
- keyRows() : Rows
- noInputRow() : Rows
Methods
__construct()
public
__construct(GroupBy $groupBy, GroupByShape $shape, Backend $backend) : mixed
Parameters
- $groupBy : GroupBy
- $shape : GroupByShape
- $backend : Backend
absorbEarlier()
public
absorbEarlier(self $earlier, array<int, int> $groups, Backend $backend) : void
Parameters
- $earlier : self
- $groups : array<int, int>
-
the ids in $earlier to absorb, whose rows came before every row of this one
- $backend : Backend
accumulate()
public
accumulate(Rows $batch, Backend $backend) : void
Parameters
count()
public
count() : int
Return values
intflush()
public
flush(int<1, max> $batchSize, Backend $backend) : Generator<string|int, Rows>
Parameters
- $batchSize : int<1, max>
- $backend : Backend
Return values
Generator<string|int, Rows>keyRows()
public
keyRows(array<int, int> $groups, Backend $backend) : Rows
Parameters
- $groups : array<int, int>
- $backend : Backend
Return values
RowsnoInputRow()
public
noInputRow(Backend $backend) : Rows
Parameters
- $backend : Backend