Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.apache.derby.impl.sql.execute
Class GenericAggregator  view GenericAggregator download GenericAggregator.java

java.lang.Object
  extended byorg.apache.derby.impl.sql.execute.GenericAggregator

class GenericAggregator
extends java.lang.Object

Adaptor that sits between execution layer and aggregates.


Field Summary
(package private)  AggregatorInfo aggInfo
           
(package private)  int aggregatorColumnId
           
private  org.apache.derby.iapi.sql.execute.ExecAggregator cachedAggregator
           
private  org.apache.derby.iapi.services.loader.ClassFactory cf
           
private  TemporaryRowHolderResultSet execResultSet
           
private  int inputColumnId
           
private  org.apache.derby.iapi.sql.ResultDescription inputColumnResultDescription
           
private  int resultColumnId
           
private  org.apache.derby.iapi.sql.execute.ExecRow[] rowArray
           
 
Constructor Summary
(package private) GenericAggregator(AggregatorInfo aggInfo, org.apache.derby.iapi.services.loader.ClassFactory cf)
          Constructor:
 
Method Summary
(package private)  void accumulate(org.apache.derby.iapi.types.DataValueDescriptor inputColumn, org.apache.derby.iapi.types.DataValueDescriptor aggregatorColumn)
          Accumulate the aggregate results.
(package private)  void accumulate(org.apache.derby.iapi.sql.execute.ExecRow inputRow, org.apache.derby.iapi.sql.execute.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(org.apache.derby.iapi.sql.execute.ExecRow row)
          Get the results of the aggregation and put it in the result column.
(package private)  AggregatorInfo getAggregatorInfo()
           
(package private)  org.apache.derby.iapi.sql.execute.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)  void initialize(org.apache.derby.iapi.sql.execute.ExecRow row)
          Initialize the aggregator
(package private)  void merge(org.apache.derby.iapi.sql.execute.ExecRow inputRow, org.apache.derby.iapi.sql.execute.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(org.apache.derby.iapi.services.io.Storable aggregatorColumnIn, org.apache.derby.iapi.services.io.Storable aggregatorColumnOut)
          Merge two partial aggregations.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

aggInfo

AggregatorInfo aggInfo

aggregatorColumnId

int aggregatorColumnId

inputColumnId

private int inputColumnId

resultColumnId

private int resultColumnId

inputColumnResultDescription

private org.apache.derby.iapi.sql.ResultDescription inputColumnResultDescription

rowArray

private org.apache.derby.iapi.sql.execute.ExecRow[] rowArray

execResultSet

private TemporaryRowHolderResultSet execResultSet

cf

private final org.apache.derby.iapi.services.loader.ClassFactory cf

cachedAggregator

private org.apache.derby.iapi.sql.execute.ExecAggregator cachedAggregator
Constructor Detail

GenericAggregator

GenericAggregator(AggregatorInfo aggInfo,
                  org.apache.derby.iapi.services.loader.ClassFactory cf)
Constructor:

Method Detail

initialize

void initialize(org.apache.derby.iapi.sql.execute.ExecRow row)
          throws org.apache.derby.iapi.error.StandardException
Initialize the aggregator


accumulate

void accumulate(org.apache.derby.iapi.sql.execute.ExecRow inputRow,
                org.apache.derby.iapi.sql.execute.ExecRow accumulateRow)
          throws org.apache.derby.iapi.error.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

void accumulate(java.lang.Object[] inputRow,
                java.lang.Object[] accumulateRow)
          throws org.apache.derby.iapi.error.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

void accumulate(org.apache.derby.iapi.types.DataValueDescriptor inputColumn,
                org.apache.derby.iapi.types.DataValueDescriptor aggregatorColumn)
          throws org.apache.derby.iapi.error.StandardException
Accumulate the aggregate results. This is the guts of the aggregation. We will call the user aggregate on itself to do the aggregation.


merge

void merge(org.apache.derby.iapi.sql.execute.ExecRow inputRow,
           org.apache.derby.iapi.sql.execute.ExecRow mergeRow)
     throws org.apache.derby.iapi.error.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

void merge(java.lang.Object[] inputRow,
           java.lang.Object[] mergeRow)
     throws org.apache.derby.iapi.error.StandardException
Merge the aggregate results. This is the guts of the aggregation. We will call the user aggregate on itself to do the aggregation.


finish

boolean finish(org.apache.derby.iapi.sql.execute.ExecRow row)
         throws org.apache.derby.iapi.error.StandardException
Get the results of the aggregation and put it in the result column.


getAggregatorInstance

org.apache.derby.iapi.sql.execute.ExecAggregator getAggregatorInstance()
                                                                 throws org.apache.derby.iapi.error.StandardException
Get a new instance of the aggregator and initialize it.


getColumnId

int getColumnId()
Return the column id that is being aggregated


merge

void merge(org.apache.derby.iapi.services.io.Storable aggregatorColumnIn,
           org.apache.derby.iapi.services.io.Storable aggregatorColumnOut)
     throws org.apache.derby.iapi.error.StandardException
Merge two partial aggregations. This is how the sorter merges partial aggregates.


getAggregatorInfo

AggregatorInfo getAggregatorInfo()