| Modifier and Type | Field and Description |
|---|---|
| private List | |
| private List | |
| private long | |
| public boolean | |
| public boolean | |
| private int | |
| private int | |
| private ColumnOrdering[] | |
| private ExecIndexRow[] | |
| private boolean | |
| private boolean | |
| public int | |
| public int | |
| private ScanController | |
| public Properties | |
| private ExecIndexRow | |
| private ExecIndexRow | |
| private TransactionController | |
| private boolean |
| Access | Constructor and Description |
|---|---|
| pack-priv | GroupedAggregateResultSet(NoPutResultSet
input result set s, boolean true if the source results are in sorted order isInSortedOrder, int indicates the number of the
SavedObject off of the PreparedStatement that holds the
AggregatorInfoList used by this routine. aggregateItem, int indicates the number of the
SavedObject off of the PreparedStatement that holds the
ColumOrdering array used by this routine orderingItem, Activation activation a, int saved object that builds an empty output row ra, int approx row size, passed to sorter maxRowSize, int The resultSetNumber for this result set resultSetNumber, double optimizerEstimatedRowCount, double optimizerEstimatedCost, boolean isRollup)Constructor |
| Modifier and Type | Method and Description |
|---|---|
| public void | close()
Overrides org. Implements org. If the result set has been opened, close the open scan. |
| public void | |
| private ExecRow | |
| public ExecRow | Returns: the last row returned;Implements org. This result set has its row from the last fetch done. |
| public ExecRow | Returns: the next row in the resultImplements abstract org. Implements org. Return the next row. |
| private ExecIndexRow | |
| private ExecIndexRow | |
| private ExecIndexRow | |
| public RowLocation | Returns: the row location of the current cursor row.Implements org. This result set has its row location from the last fetch done. |
| public long | Returns: long The total amount of time spent (in milliseconds).CURRENT_RESULTSET_ONLY - time spent only in this ResultSet
ENTIRE_RESULTSET_TREE - time spent in this ResultSet and below. type)Implements org. Return the total amount of time spent in this ResultSet |
| private void | |
| private void | initializeVectorAggregation(ExecRow
the row to initialize row)Run the aggregator initialization method for each aggregator in the row. |
| private ScanController | |
| private ExecRow | |
| private void | mergeVectorAggregates(ExecRow
the row to merge newRow, ExecRow the row to merge into currRow, int level)Run the aggregator merge method for each aggregator in the row. |
| private int | |
| public void | |
| private int | Returns: The order index number which first distinguished these rows, or order.length if the rows match.The current row. currRow, ExecRow The new row. newRow)Return whether or not the new row has the same values for the grouping columns as the current row. |
| private void |
| distinctValues | back to summary |
|---|---|
| private List<List<Set<DataValueDescriptor>>> distinctValues | |
| finishedResults | back to summary |
|---|---|
| private List<ExecRow> finishedResults | |
| genericSortId | back to summary |
|---|---|
| private long genericSortId | |
| hasDistinctAggregate | back to summary |
|---|---|
| public boolean hasDistinctAggregate | |
| isInSortedOrder | back to summary |
|---|---|
| public boolean isInSortedOrder | |
| maxRowSize | back to summary |
|---|---|
| private int maxRowSize | |
| numDistinctAggs | back to summary |
|---|---|
| private int numDistinctAggs | |
| order | back to summary |
|---|---|
| private ColumnOrdering[] order | |
| resultRows | back to summary |
|---|---|
| private ExecIndexRow[] resultRows | |
| resultsComplete | back to summary |
|---|---|
| private boolean resultsComplete | |
| rollup | back to summary |
|---|---|
| private boolean rollup | |
| rowsInput | back to summary |
|---|---|
| public int rowsInput | |
| rowsReturned | back to summary |
|---|---|
| public int rowsReturned | |
| scanController | back to summary |
|---|---|
| private ScanController scanController | |
| sortProperties | back to summary |
|---|---|
| public Properties sortProperties | |
| sortResultRow | back to summary |
|---|---|
| private ExecIndexRow sortResultRow | |
| sourceExecIndexRow | back to summary |
|---|---|
| private ExecIndexRow sourceExecIndexRow | |
| tc | back to summary |
|---|---|
| private TransactionController tc Hides org. | |
| usingAggregateObserver | back to summary |
|---|---|
| private boolean usingAggregateObserver | |
| GroupedAggregateResultSet | back to summary |
|---|---|
| pack-priv GroupedAggregateResultSet(NoPutResultSet s, boolean isInSortedOrder, int aggregateItem, int orderingItem, Activation a, int ra, int maxRowSize, int resultSetNumber, double optimizerEstimatedRowCount, double optimizerEstimatedCost, boolean isRollup) throws StandardException Constructor
| |
| close | back to summary |
|---|---|
| public void close() throws StandardException Overrides org. Implements org. If the result set has been opened, close the open scan.
| |
| closeSource | back to summary |
|---|---|
| public void closeSource() throws StandardException Close the source of whatever we have been scanning.
| |
| finalizeResults | back to summary |
|---|---|
| private ExecRow finalizeResults() throws StandardException | |
| getCurrentRow | back to summary |
|---|---|
| public ExecRow getCurrentRow() throws StandardException Implements org. This result set has its row from the last fetch done. If the cursor is closed, a null is returned.
| |
| getNextRowCore | back to summary |
|---|---|
| public ExecRow getNextRowCore() throws StandardException Implements abstract org. Implements org. Return the next row.
| |
| getNextRowFromRS | back to summary |
|---|---|
| private ExecIndexRow getNextRowFromRS() throws StandardException Get the next output row for processing | |
| getRowFromResultSet | back to summary |
|---|---|
| private ExecIndexRow getRowFromResultSet() throws StandardException Get a row from the input result set. | |
| getRowFromSorter | back to summary |
|---|---|
| private ExecIndexRow getRowFromSorter() throws StandardException Get a row from the sorter. Side effects: sets currentRow. | |
| getRowLocation | back to summary |
|---|---|
| public RowLocation getRowLocation() throws StandardException Implements org. This result set has its row location from the last fetch done. If the cursor is closed, a null is returned.
| |
| getTimeSpent | back to summary |
|---|---|
| public long getTimeSpent(int type) Implements org. Return the total amount of time spent in this ResultSet
| |
| initializeDistinctMaps | back to summary |
|---|---|
| private void initializeDistinctMaps(int r, boolean allocate) throws StandardException | |
| initializeVectorAggregation | back to summary |
|---|---|
| private void initializeVectorAggregation(ExecRow row) throws StandardException Run the aggregator initialization method for each aggregator in the row. Accumulate the input column. Warning initializiation performs accumulation -- no need to accumulate a row that has been passed to initialization.
| |
| loadSorter | back to summary |
|---|---|
| private ScanController loadSorter() throws StandardException Load up the sorter. Feed it every row from the source scan. When done, close the source scan and open the sort. Return the sort scan controller.
| |
| makeCurrent | back to summary |
|---|---|
| private ExecRow makeCurrent(Object row) throws StandardException | |
| mergeVectorAggregates | back to summary |
|---|---|
| private void mergeVectorAggregates(ExecRow newRow, ExecRow currRow, int level) throws StandardException Run the aggregator merge method for each aggregator in the row.
| |
| numGCols | back to summary |
|---|---|
| private int numGCols() Return the number of grouping columns. Since some additional sort columns may have been included in the sort for DISTINCT aggregates, this function is used to ignore those columns when computing the grouped results. | |
| openCore | back to summary |
|---|---|
| public void openCore() throws StandardException Implements org. Open the scan. Load the sorter and prepare to get rows from it.
| |
| sameGroupingValues | back to summary |
|---|---|
| private int sameGroupingValues(ExecRow currRow, ExecRow newRow) throws StandardException Return whether or not the new row has the same values for the grouping columns as the current row. (This allows us to process in-order group bys without a sorter.)
| |
| setRollupColumnsToNull | back to summary |
|---|---|
| private void setRollupColumnsToNull(ExecRow row, int resultNum) throws StandardException | |