com.illumon.iris.db.v2.by.DoubleAddOnlySortedFirstOrLastChunkedOperator

All Implemented Interfaces:: IterativeChunkedAggregationOperator

public class DoubleAddOnlySortedFirstOrLastChunkedOperator
extends Object

Chunked aggregation operator for sorted first/last-by using a double sort-column on add-only tables.

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.by.IterativeChunkedAggregationOperator
IterativeChunkedAggregationOperator.BucketedContext, IterativeChunkedAggregationOperator.SingletonContext
Field Summary

Fields inherited from interface com.illumon.iris.db.v2.by.IterativeChunkedAggregationOperator
ZERO_LENGTH_ITERATIVE_CHUNKED_AGGREGATION_OPERATOR_ARRAY

Method Summary

Modifier and Type	Method	Description
`void`	`addChunk(IterativeChunkedAggregationOperator.BucketedContext bucketedContext, Chunk<? extends Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> inputIndices, IntChunk<Attributes.KeyIndices> destinations, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length, WritableBooleanChunk<Attributes.Values> stateModified)`	Aggregate a chunk of data into the result columns.
`boolean`	`addChunk(IterativeChunkedAggregationOperator.SingletonContext singletonContext, int chunkSize, Chunk<? extends Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> inputIndices, long destination)`	Aggregate a chunk of data into the result columns.
`void`	`ensureCapacity(long tableSize)`	Ensure that this operator can handle destinations up to tableSize - 1.
`Map<String,? extends ColumnSource<?>>`	`getResultColumns()`	Return a map of result columns produced by this operator.
`void`	`modifyChunk(IterativeChunkedAggregationOperator.BucketedContext bucketedContext, Chunk<? extends Attributes.Values> previousValues, Chunk<? extends Attributes.Values> newValues, LongChunk<? extends Attributes.KeyIndices> postShiftIndices, IntChunk<Attributes.KeyIndices> destinations, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length, WritableBooleanChunk<Attributes.Values> stateModified)`	Modify a chunk of data previously aggregated into the result columns using a parallel chunk of new values.
`boolean`	`modifyChunk(IterativeChunkedAggregationOperator.SingletonContext singletonContext, int chunkSize, Chunk<? extends Attributes.Values> previousValues, Chunk<? extends Attributes.Values> newValues, LongChunk<? extends Attributes.KeyIndices> postShiftIndices, long destination)`	Modify a chunk of data previously aggregated into the result columns using a parallel chunk of new values.
`void`	`modifyIndices(IterativeChunkedAggregationOperator.BucketedContext context, LongChunk<? extends Attributes.KeyIndices> inputIndices, IntChunk<Attributes.KeyIndices> destinations, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length, WritableBooleanChunk<Attributes.Values> stateModified)`	Called with the modified indices when `IterativeChunkedAggregationOperator.requiresIndices()` returns true if our input columns have not changed (or we have none).
`boolean`	`modifyIndices(IterativeChunkedAggregationOperator.SingletonContext context, LongChunk<? extends Attributes.KeyIndices> indices, long destination)`	Called with the modified indices when `IterativeChunkedAggregationOperator.requiresIndices()` returns true if our input columns have not changed (or we have none).
`void`	`removeChunk(IterativeChunkedAggregationOperator.BucketedContext bucketedContext, Chunk<? extends Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> inputIndices, IntChunk<Attributes.KeyIndices> destinations, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length, WritableBooleanChunk<Attributes.Values> stateModified)`	Remove a chunk of data previously aggregated into the result columns.
`boolean`	`removeChunk(IterativeChunkedAggregationOperator.SingletonContext singletonContext, int chunkSize, Chunk<? extends Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> inputIndices, long destination)`	Remove a chunk of data previously aggregated into the result columns.
`boolean`	`requiresIndices()`	Whether the operator requires indices.
`void`	shiftChunk(IterativeChunkedAggregationOperator.BucketedContext bucketedContext, Chunk<? extends Attributes.Values> previousValues, Chunk<? extends Attributes.Values> newValues, LongChunk<? extends Attributes.KeyIndices> preShiftIndices, LongChunk<? extends Attributes.KeyIndices> postShiftIndices, IntChunk<Attributes.KeyIndices> destinations, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length, WritableBooleanChunk<Attributes.Values> stateModified)	Called with shifted indices when `IterativeChunkedAggregationOperator.requiresIndices()` returns true, including shifted same-slot modifies.
`boolean`	`shiftChunk(IterativeChunkedAggregationOperator.SingletonContext singletonContext, Chunk<? extends Attributes.Values> previousValues, Chunk<? extends Attributes.Values> newValues, LongChunk<? extends Attributes.KeyIndices> preInputIndices, LongChunk<? extends Attributes.KeyIndices> postInputIndices, long destination)`	Shift a chunk of data previously aggregated into the result columns, including shifted same-slot modifies..
`void`	`startTrackingPrevValues()`	Called after initialization; when the operator's result columns must have previous tracking enabled.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.illumon.iris.db.v2.by.IterativeChunkedAggregationOperator

addIndex, initializeRefreshing, makeBucketedContext, makeSingletonContext, propagateFailure, propagateInitialState, propagateUpdates, resetForStep, unchunkedIndex

Method Details
- ensureCapacity
  
  public void ensureCapacity(long tableSize)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Ensure that this operator can handle destinations up to tableSize - 1.
  
  Specified by:
  
  ensureCapacity in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  tableSize - the new size of the table
- addChunk
  
  public void addChunk(IterativeChunkedAggregationOperator.BucketedContext bucketedContext, @NotNull Chunk<? extends Attributes.Values> values, @NotNull LongChunk<? extends Attributes.KeyIndices> inputIndices, @NotNull IntChunk<Attributes.KeyIndices> destinations, @NotNull IntChunk<Attributes.ChunkPositions> startPositions, @NotNull IntChunk<Attributes.ChunkLengths> length, @NotNull WritableBooleanChunk<Attributes.Values> stateModified)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Aggregate a chunk of data into the result columns.
  
  Parameters:
  
  bucketedContext - the operator-specific context
  
  values - a chunk of values to aggregate
  
  inputIndices - the input indices, in post-shift space
  
  destinations - the destinations in resultColumn to aggregate into, parallel with startPositions and length
  
  startPositions - the starting positions in the chunk for each destination
  
  length - the number of values in the chunk for each destination
  
  stateModified - a boolean output array, parallel to destinations, which is set to true if the corresponding destination has been modified
- addChunk
  
  public boolean addChunk(IterativeChunkedAggregationOperator.SingletonContext singletonContext, int chunkSize, @NotNull Chunk<? extends Attributes.Values> values, @NotNull LongChunk<? extends Attributes.KeyIndices> inputIndices, long destination)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Aggregate a chunk of data into the result columns.
  
  Parameters:
  
  singletonContext - the operator-specific context
  
  chunkSize - the size of the addition
  
  values - the values to aggregate
  
  inputIndices - the input indices, in post-shift space
  
  destination - the destination in the result columns
  
  Returns:
  
  true if the state was modified, false otherwise
- removeChunk
  
  public void removeChunk(IterativeChunkedAggregationOperator.BucketedContext bucketedContext, Chunk<? extends Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> inputIndices, IntChunk<Attributes.KeyIndices> destinations, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length, WritableBooleanChunk<Attributes.Values> stateModified)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Remove a chunk of data previously aggregated into the result columns.
  
  Specified by:
  
  removeChunk in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  bucketedContext - the operator-specific context
  
  values - a chunk of values that have been previously aggregated.
  
  inputIndices - the input indices, in pre-shift space
  
  destinations - the destinations in resultColumn to remove the values from, parallel with startPositions and length
  
  startPositions - the starting positions in the chunk for each destination
  
  length - the number of values in the chunk for each destination
  
  stateModified - a boolean output array, parallel to destinations, which is set to true if the corresponding destination has been modified
- modifyChunk
  
  public void modifyChunk(IterativeChunkedAggregationOperator.BucketedContext bucketedContext, Chunk<? extends Attributes.Values> previousValues, Chunk<? extends Attributes.Values> newValues, LongChunk<? extends Attributes.KeyIndices> postShiftIndices, IntChunk<Attributes.KeyIndices> destinations, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length, WritableBooleanChunk<Attributes.Values> stateModified)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Modify a chunk of data previously aggregated into the result columns using a parallel chunk of new values. Never includes modifies that have been shifted if IterativeChunkedAggregationOperator.requiresIndices() returns true - those are handled in IterativeChunkedAggregationOperator.shiftChunk(BucketedContext, Chunk, Chunk, LongChunk, LongChunk, IntChunk, IntChunk, IntChunk, WritableBooleanChunk).
  
  Specified by:
  
  modifyChunk in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  bucketedContext - the operator-specific context
  
  previousValues - a chunk of values that have been previously aggregated
  
  newValues - a chunk of values to aggregate
  
  postShiftIndices - the input indices, in post-shift space
  
  destinations - the destinations in resultColumn to remove the values from, parallel with startPositions and length
  
  startPositions - the starting positions in the chunk for each destination
  
  length - the number of values in the chunk for each destination
  
  stateModified - a boolean output array, parallel to destinations, which is set to true if the corresponding destination has been modified
- shiftChunk
  
  public void shiftChunk(IterativeChunkedAggregationOperator.BucketedContext bucketedContext, Chunk<? extends Attributes.Values> previousValues, Chunk<? extends Attributes.Values> newValues, LongChunk<? extends Attributes.KeyIndices> preShiftIndices, LongChunk<? extends Attributes.KeyIndices> postShiftIndices, IntChunk<Attributes.KeyIndices> destinations, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length, WritableBooleanChunk<Attributes.Values> stateModified)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Called with shifted indices when IterativeChunkedAggregationOperator.requiresIndices() returns true, including shifted same-slot modifies.
  
  Specified by:
  
  shiftChunk in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  bucketedContext - the operator-specific context
  
  previousValues - a chunk of values that have been previously aggregated.
  
  newValues - a chunk of values to aggregate
  
  preShiftIndices - the input indices, in pre-shift space
  
  postShiftIndices - the input indices, in post-shift space
  
  destinations - the destinations in resultColumn to aggregate into, parallel with startPositions and length
  
  startPositions - the starting positions in the chunk for each destination
  
  length - the number of values in the chunk for each destination
  
  stateModified - a boolean output array, parallel to destinations, which is set to true if the corresponding destination has been modified
- modifyIndices
  
  public void modifyIndices(IterativeChunkedAggregationOperator.BucketedContext context, LongChunk<? extends Attributes.KeyIndices> inputIndices, IntChunk<Attributes.KeyIndices> destinations, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length, WritableBooleanChunk<Attributes.Values> stateModified)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Called with the modified indices when IterativeChunkedAggregationOperator.requiresIndices() returns true if our input columns have not changed (or we have none).
  
  Specified by:
  
  modifyIndices in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  context - the operator-specific context
  
  inputIndices - the input indices, in post-shift space
  
  destinations - the destinations in resultColumn to aggregate into, parallel with startPositions and length
  
  startPositions - the starting positions in the chunk for each destination
  
  length - the number of values in the chunk for each destination
  
  stateModified - a boolean output array, parallel to destinations, which is set to true if the corresponding destination has been modified
- removeChunk
  
  public boolean removeChunk(IterativeChunkedAggregationOperator.SingletonContext singletonContext, int chunkSize, Chunk<? extends Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> inputIndices, long destination)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Remove a chunk of data previously aggregated into the result columns.
  
  Specified by:
  
  removeChunk in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  singletonContext - the operator-specific context
  
  chunkSize - the size of the removal
  
  values - the values to remove from the aggregation
  
  inputIndices - the input indices, in pre-shift space
  
  destination - the destination in the result columns
  
  Returns:
  
  true if the state was modified, false otherwise
- modifyChunk
  
  public boolean modifyChunk(IterativeChunkedAggregationOperator.SingletonContext singletonContext, int chunkSize, Chunk<? extends Attributes.Values> previousValues, Chunk<? extends Attributes.Values> newValues, LongChunk<? extends Attributes.KeyIndices> postShiftIndices, long destination)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Modify a chunk of data previously aggregated into the result columns using a parallel chunk of new values. Never includes modifies that have been shifted if IterativeChunkedAggregationOperator.requiresIndices() returns true - those are handled in IterativeChunkedAggregationOperator.shiftChunk(SingletonContext, Chunk, Chunk, LongChunk, LongChunk, long).
  
  Specified by:
  
  modifyChunk in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  singletonContext - the operator-specific context
  
  chunkSize - the size of the modification
  
  previousValues - a chunk of values that have been previously aggregated.
  
  newValues - a chunk of values to aggregate
  
  postShiftIndices - the input indices, in post-shift space
  
  Returns:
  
  true if the state was modified, false otherwise
- shiftChunk
  
  public boolean shiftChunk(IterativeChunkedAggregationOperator.SingletonContext singletonContext, Chunk<? extends Attributes.Values> previousValues, Chunk<? extends Attributes.Values> newValues, LongChunk<? extends Attributes.KeyIndices> preInputIndices, LongChunk<? extends Attributes.KeyIndices> postInputIndices, long destination)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Shift a chunk of data previously aggregated into the result columns, including shifted same-slot modifies..
  
  Specified by:
  
  shiftChunk in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  singletonContext - the operator-specific context
  
  previousValues - a chunk of values that have been previously aggregated.
  
  newValues - a chunk of values to aggregate
  
  preInputIndices - the input indices, in pre-shift space
  
  postInputIndices - the input indices, in post-shift space
  
  destination - the destination in the result columns
  
  Returns:
  
  true if the result should be considered modified
- modifyIndices
  
  public boolean modifyIndices(IterativeChunkedAggregationOperator.SingletonContext context, LongChunk<? extends Attributes.KeyIndices> indices, long destination)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Called with the modified indices when IterativeChunkedAggregationOperator.requiresIndices() returns true if our input columns have not changed (or we have none).
  
  Specified by:
  
  modifyIndices in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  context - the operator-specific context
  
  indices - the modified indices for a given destination, in post-shift space
  
  destination - the destination that was modified
  
  Returns:
  
  true if the result should be considered modified
- getResultColumns
  
  public Map<String,? extends ColumnSource<?>> getResultColumns()
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Return a map of result columns produced by this operator.
  
  Specified by:
  
  getResultColumns in interface IterativeChunkedAggregationOperator
  
  Returns:
  
  a map of name to columns for the result table
- startTrackingPrevValues
  
  public void startTrackingPrevValues()
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Called after initialization; when the operator's result columns must have previous tracking enabled.
  
  Specified by:
  
  startTrackingPrevValues in interface IterativeChunkedAggregationOperator
- requiresIndices
  
  public boolean requiresIndices()
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Whether the operator requires indices. This implies that the operator must process shifts (i.e. IterativeChunkedAggregationOperator.shiftChunk(com.illumon.iris.db.v2.by.IterativeChunkedAggregationOperator.BucketedContext, com.illumon.iris.db.v2.sources.chunk.Chunk<? extends com.illumon.iris.db.v2.sources.chunk.Attributes.Values>, com.illumon.iris.db.v2.sources.chunk.Chunk<? extends com.illumon.iris.db.v2.sources.chunk.Attributes.Values>, com.illumon.iris.db.v2.sources.chunk.LongChunk<? extends com.illumon.iris.db.v2.sources.chunk.Attributes.KeyIndices>, com.illumon.iris.db.v2.sources.chunk.LongChunk<? extends com.illumon.iris.db.v2.sources.chunk.Attributes.KeyIndices>, com.illumon.iris.db.v2.sources.chunk.IntChunk<com.illumon.iris.db.v2.sources.chunk.Attributes.KeyIndices>, com.illumon.iris.db.v2.sources.chunk.IntChunk<com.illumon.iris.db.v2.sources.chunk.Attributes.ChunkPositions>, com.illumon.iris.db.v2.sources.chunk.IntChunk<com.illumon.iris.db.v2.sources.chunk.Attributes.ChunkLengths>, com.illumon.iris.db.v2.sources.chunk.WritableBooleanChunk<com.illumon.iris.db.v2.sources.chunk.Attributes.Values>)), and must observe modifications even when its input columns (if any) are not modified (i.e. IterativeChunkedAggregationOperator.modifyIndices(com.illumon.iris.db.v2.by.IterativeChunkedAggregationOperator.BucketedContext, com.illumon.iris.db.v2.sources.chunk.LongChunk<? extends com.illumon.iris.db.v2.sources.chunk.Attributes.KeyIndices>, com.illumon.iris.db.v2.sources.chunk.IntChunk<com.illumon.iris.db.v2.sources.chunk.Attributes.KeyIndices>, com.illumon.iris.db.v2.sources.chunk.IntChunk<com.illumon.iris.db.v2.sources.chunk.Attributes.ChunkPositions>, com.illumon.iris.db.v2.sources.chunk.IntChunk<com.illumon.iris.db.v2.sources.chunk.Attributes.ChunkLengths>, com.illumon.iris.db.v2.sources.chunk.WritableBooleanChunk<com.illumon.iris.db.v2.sources.chunk.Attributes.Values>)).
  
  Specified by:
  
  requiresIndices in interface IterativeChunkedAggregationOperator
  
  Returns:
  
  true if the operator requires indices, false otherwise

Class DoubleAddOnlySortedFirstOrLastChunkedOperator

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.by.IterativeChunkedAggregationOperator

Field Summary

Fields inherited from interface com.illumon.iris.db.v2.by.IterativeChunkedAggregationOperator

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface com.illumon.iris.db.v2.by.IterativeChunkedAggregationOperator

Method Details