class GenericAggregator
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private AggregatorInfo |
aggInfo |
(package private) int |
aggregatorColumnId |
private ExecAggregator |
cachedAggregator |
private ClassFactory |
cf |
private int |
inputColumnId |
private int |
resultColumnId |
Constructor and Description |
---|
GenericAggregator(AggregatorInfo aggInfo,
ClassFactory cf)
Constructor:
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
accumulate(DataValueDescriptor inputColumn,
DataValueDescriptor aggregatorColumn)
Accumulate the aggregate results.
|
(package private) void |
accumulate(ExecRow inputRow,
ExecRow accumulateRow)
Accumulate the aggregate results.
|
(package private) void |
accumulate(java.lang.Object[] inputRow,
java.lang.Object[] accumulateRow)
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(ExecRow inputRow,
ExecRow mergeRow)
Merge the aggregate results.
|
(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.
|
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.13 Internals - Copyright © 2004,2016 The Apache Software Foundation. All Rights Reserved.