class GenericAggregator
extends java.lang.Object
Modifier and Type | Field | Description |
---|---|---|
private AggregatorInfo |
aggInfo |
|
(package private) int |
aggregatorColumnId |
|
private ExecAggregator |
cachedAggregator |
|
private ClassFactory |
cf |
|
private int |
inputColumnId |
|
private int |
resultColumnId |
Constructor | Description |
---|---|
GenericAggregator(AggregatorInfo aggInfo,
ClassFactory cf) |
Constructor:
|
Modifier and Type | Method | Description |
---|---|---|
(package private) void |
accumulate(java.lang.Object[] inputRow,
java.lang.Object[] accumulateRow) |
Accumulate the aggregate results.
|
(package private) void |
accumulate(ExecRow inputRow,
ExecRow accumulateRow) |
Accumulate the aggregate results.
|
(package private) void |
accumulate(DataValueDescriptor inputColumn,
DataValueDescriptor aggregatorColumn) |
Accumulate the aggregate results.
|
(package private) boolean |
finish(ExecRow row) |
Get the results of the aggregation and put it
in the result column.
|
(package private) AggregatorInfo |
getAggregatorInfo() |
|
(package private) ExecAggregator |
getAggregatorInstance() |
Get a new instance of the aggregator and initialize it.
|
(package private) int |
getColumnId() |
Return the column id that is being aggregated
|
(package private) DataValueDescriptor |
getInputColumnValue(ExecRow row) |
|
(package private) void |
initialize(ExecRow row) |
Initialize the aggregator
|
(package private) void |
merge(java.lang.Object[] inputRow,
java.lang.Object[] mergeRow) |
Merge the aggregate results.
|
(package private) void |
merge(Storable aggregatorColumnIn,
Storable aggregatorColumnOut) |
Merge two partial aggregations.
|
(package private) void |
merge(ExecRow inputRow,
ExecRow mergeRow) |
Merge the aggregate results.
|
private final AggregatorInfo aggInfo
int aggregatorColumnId
private int inputColumnId
private int resultColumnId
private final ClassFactory cf
private ExecAggregator cachedAggregator
GenericAggregator(AggregatorInfo aggInfo, ClassFactory cf)
aggInfo
- information about the user aggregatecf
- the class factory.void initialize(ExecRow row) throws StandardException
row
- the row with the aggregator to be initializedStandardException
- on errorvoid accumulate(ExecRow inputRow, ExecRow accumulateRow) throws StandardException
inputRow
- the row with the input columaccumulateRow
- the row with the aggregatorStandardException
- on errorvoid accumulate(java.lang.Object[] inputRow, java.lang.Object[] accumulateRow) throws StandardException
inputRow
- the row with the input columaccumulateRow
- the row with the aggregatorStandardException
- on errorvoid accumulate(DataValueDescriptor inputColumn, DataValueDescriptor aggregatorColumn) throws StandardException
inputColumn
- aggregatorColumn
- StandardException
- on errorvoid merge(ExecRow inputRow, ExecRow mergeRow) throws StandardException
inputRow
- the row with the input colummergeRow
- the row with the aggregatorStandardException
- on errorvoid merge(java.lang.Object[] inputRow, java.lang.Object[] mergeRow) throws StandardException
inputRow
- the row with the input colummergeRow
- the row with the aggregatorStandardException
- on errorboolean finish(ExecRow row) throws StandardException
row
- the row with the result and the aggregatorStandardException
- on errorExecAggregator getAggregatorInstance() throws StandardException
StandardException
- on errorint getColumnId()
DataValueDescriptor getInputColumnValue(ExecRow row) throws StandardException
StandardException
void merge(Storable aggregatorColumnIn, Storable aggregatorColumnOut) throws StandardException
StandardException
- on errorAggregatorInfo getAggregatorInfo()
Apache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.