| Modifier and Type | Field and Description |
|---|---|
| private final AggregatorInfo | |
| pack-priv int | |
| private ExecAggregator | |
| private final ClassFactory | |
| private int | |
| private int |
| Access | Constructor and Description |
|---|---|
| pack-priv | GenericAggregator(AggregatorInfo
information about the user aggregate aggInfo, ClassFactory the class factory. cf)Constructor: |
| Modifier and Type | Method and Description |
|---|---|
| pack-priv void | accumulate(ExecRow
the row with the input colum inputRow, ExecRow the row with the aggregator accumulateRow)Accumulate the aggregate results. |
| pack-priv void | accumulate(Object[]
the row with the input colum inputRow, Object[] the row with the aggregator accumulateRow)Accumulate the aggregate results. |
| pack-priv void | accumulate(DataValueDescriptor inputColumn, DataValueDescriptor aggregatorColumn)
Accumulate the aggregate results. |
| pack-priv boolean | |
| pack-priv AggregatorInfo | |
| pack-priv ExecAggregator | Returns: an exec aggregatorGet a new instance of the aggregator and initialize it. |
| pack-priv int | |
| pack-priv DataValueDescriptor | |
| pack-priv void | |
| pack-priv void | |
| pack-priv void | |
| pack-priv void |
| aggInfo | back to summary |
|---|---|
| private final AggregatorInfo aggInfo | |
| aggregatorColumnId | back to summary |
|---|---|
| pack-priv int aggregatorColumnId | |
| cachedAggregator | back to summary |
|---|---|
| private ExecAggregator cachedAggregator | |
| cf | back to summary |
|---|---|
| private final ClassFactory cf | |
| inputColumnId | back to summary |
|---|---|
| private int inputColumnId | |
| resultColumnId | back to summary |
|---|---|
| private int resultColumnId | |
| GenericAggregator | back to summary |
|---|---|
| pack-priv GenericAggregator(AggregatorInfo aggInfo, ClassFactory cf) Constructor:
| |
| accumulate | back to summary |
|---|---|
| pack-priv void accumulate(ExecRow inputRow, ExecRow accumulateRow) throws StandardException Accumulate the aggregate results. This is the guts of the aggregation. We will call the user aggregate on itself to do the aggregation.
| |
| accumulate | back to summary |
|---|---|
| pack-priv void accumulate(Object[] inputRow, Object[] accumulateRow) throws StandardException Accumulate the aggregate results. This is the guts of the aggregation. We will call the user aggregate on itself to do the aggregation.
| |
| accumulate | back to summary |
|---|---|
| pack-priv void accumulate(DataValueDescriptor inputColumn, DataValueDescriptor aggregatorColumn) throws StandardException Accumulate the aggregate results. This is the guts of the aggregation. We will call the user aggregate on itself to do the aggregation.
| |
| finish | back to summary |
|---|---|
| pack-priv boolean finish(ExecRow row) throws StandardException Get the results of the aggregation and put it in the result column.
| |
| getAggregatorInfo | back to summary |
|---|---|
| pack-priv AggregatorInfo getAggregatorInfo() | |
| getAggregatorInstance | back to summary |
|---|---|
| pack-priv ExecAggregator getAggregatorInstance() throws StandardException Get a new instance of the aggregator and initialize it.
| |
| getColumnId | back to summary |
|---|---|
| pack-priv int getColumnId() Return the column id that is being aggregated | |
| getInputColumnValue | back to summary |
|---|---|
| pack-priv DataValueDescriptor getInputColumnValue(ExecRow row) throws StandardException | |
| initialize | back to summary |
|---|---|
| pack-priv void initialize(ExecRow row) throws StandardException Initialize the aggregator
| |
| merge | back to summary |
|---|---|
| pack-priv void merge(ExecRow inputRow, ExecRow mergeRow) throws StandardException Merge the aggregate results. This is the guts of the aggregation. We will call the user aggregate on itself to do the aggregation.
| |
| merge | back to summary |
|---|---|
| pack-priv void merge(Object[] inputRow, Object[] mergeRow) throws StandardException Merge the aggregate results. This is the guts of the aggregation. We will call the user aggregate on itself to do the aggregation.
| |
| merge | back to summary |
|---|---|
| pack-priv void merge(Storable aggregatorColumnIn, Storable aggregatorColumnOut) throws StandardException Merge two partial aggregations. This is how the sorter merges partial aggregates.
| |