| Modifier and Type | Field and Description |
|---|---|
| protected int | |
| protected boolean | |
| private boolean | |
| public int | |
| public boolean | |
| protected ExecIndexRow |
| Access | Constructor and Description |
|---|---|
| pack-priv | ScalarAggregateResultSet(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, Activation activation a, int saved object that builds an empty output row ra, int The resultSetNumber for this result set resultSetNumber, boolean singleInputRow, double optimizerEstimatedRowCount, double optimizerEstimatedCost)Constructor |
| Modifier and Type | Method and Description |
|---|---|
| protected void | accumulateScalarAggregation(ExecRow
the input row inputRow, ExecRow the row with the accumulator (may be the same as the input row. accumulateRow, boolean does this scan have distinct
aggregates. Used to figure out whether to merge
or accumulate nondistinct aggregates. hasDistinctAggregates)Run accumulation on every aggregate in this row. |
| public void | close()
Overrides org. Implements org. If the result set has been opened, close the open scan. |
| 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. |
| public ExecIndexRow | getRowFromResultSet(boolean
- true of the row should be cloned doClone)Get a row from the input result set. |
| 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 | |
| public void | |
| public void | reopenCore()
Overrides org. Implements org. reopen a scan on the table. |
| countOfRows | back to summary |
|---|---|
| protected int countOfRows | |
| isInSortedOrder | back to summary |
|---|---|
| protected boolean isInSortedOrder | |
| nextSatisfied | back to summary |
|---|---|
| private boolean nextSatisfied | |
| rowsInput | back to summary |
|---|---|
| public int rowsInput | |
| singleInputRow | back to summary |
|---|---|
| public boolean singleInputRow | |
| sourceExecIndexRow | back to summary |
|---|---|
| protected ExecIndexRow sourceExecIndexRow | |
| ScalarAggregateResultSet | back to summary |
|---|---|
| pack-priv ScalarAggregateResultSet(NoPutResultSet s, boolean isInSortedOrder, int aggregateItem, Activation a, int ra, int resultSetNumber, boolean singleInputRow, double optimizerEstimatedRowCount, double optimizerEstimatedCost) throws StandardException Constructor
| |
| accumulateScalarAggregation | back to summary |
|---|---|
| protected void accumulateScalarAggregation(ExecRow inputRow, ExecRow accumulateRow, boolean hasDistinctAggregates) throws StandardException Run accumulation on every aggregate in this row. This method is useful when draining the source or sorter, depending on whether or not there were any distinct aggregates. Remember, if there are distinct aggregates, then the non-distinct aggregates were calculated on the way into the sorter and only the distinct aggregates will be accumulated here. Otherwise, all aggregates will be accumulated here.
| |
| close | back to summary |
|---|---|
| public void close() throws StandardException Overrides org. Implements org. If the result set has been opened, close the open scan.
| |
| 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. If it is a scalar aggregate scan
| |
| getRowFromResultSet | back to summary |
|---|---|
| public ExecIndexRow getRowFromResultSet(boolean doClone) throws StandardException Get a row from the input result set.
| |
| getRowLocation | back to summary |
|---|---|
| public RowLocation getRowLocation() throws StandardException Implements org. This result set has its row location from the last fetch done. Always returns null.
| |
| getTimeSpent | back to summary |
|---|---|
| public long getTimeSpent(int type) Implements org. Return the total amount of time spent in this ResultSet
| |
| initializeScalarAggregation | back to summary |
|---|---|
| private void initializeScalarAggregation(ExecRow row) throws StandardException | |
| openCore | back to summary |
|---|---|
| public void openCore() throws StandardException Implements org. Open the scan. Load the sorter and prepare to get rows from it.
| |
| reopenCore | back to summary |
|---|---|
| public void reopenCore() throws StandardException Overrides org. Implements org. reopen a scan on the table. scan parameters are evaluated at each open, so there is probably some way of altering their values...
| |