com.illumon.iris.db.v2.by.ssmminmax.SsmChunkedMinMaxOperator

All Implemented Interfaces:: IterativeChunkedAggregationOperator

public class SsmChunkedMinMaxOperator
extends Object
implements IterativeChunkedAggregationOperator

Iterative average operator.

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
Constructor Summary

Constructors

Constructor Description

SsmChunkedMinMaxOperator(Class<?> type, boolean minimum, String name)

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.
`IterativeChunkedAggregationOperator.BucketedContext`	`makeBucketedContext(int size)`	Make a `IterativeChunkedAggregationOperator.BucketedContext` suitable for this operator if necessary.
`IterativeChunkedAggregationOperator`	`makeSecondaryOperator(boolean isMinimum, String resultName)`
`IterativeChunkedAggregationOperator.SingletonContext`	`makeSingletonContext(int size)`	Make a `IterativeChunkedAggregationOperator.SingletonContext` suitable for this operator if necessary.
`void`	`modifyChunk(IterativeChunkedAggregationOperator.BucketedContext bucketedContext, Chunk<? extends Attributes.Values> preValues, Chunk<? extends Attributes.Values> postValues, 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> preValues, Chunk<? extends Attributes.Values> postValues, 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`	`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.
`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, modifyIndices, modifyIndices, propagateFailure, propagateInitialState, propagateUpdates, requiresIndices, resetForStep, shiftChunk, shiftChunk, unchunkedIndex

Constructor Details
- SsmChunkedMinMaxOperator
  
  public SsmChunkedMinMaxOperator(Class<?> type, boolean minimum, String name)
Method Details
- addChunk
  
  public 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)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Aggregate a chunk of data into the result columns.
  
  Specified by:
  
  addChunk in interface IterativeChunkedAggregationOperator
  
  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
- 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> preValues, Chunk<? extends Attributes.Values> postValues, 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
  
  preValues - a chunk of values that have been previously aggregated
  
  postValues - 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
- addChunk
  
  public boolean addChunk(IterativeChunkedAggregationOperator.SingletonContext singletonContext, int chunkSize, Chunk<? extends Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> inputIndices, long destination)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Aggregate a chunk of data into the result columns.
  
  Specified by:
  
  addChunk in interface IterativeChunkedAggregationOperator
  
  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 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> preValues, Chunk<? extends Attributes.Values> postValues, 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
  
  preValues - a chunk of values that have been previously aggregated.
  
  postValues - a chunk of values to aggregate
  
  postShiftIndices - the input indices, in post-shift space
  
  Returns:
  
  true if the state was modified, false otherwise
- 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
- 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
- makeBucketedContext
  
  public IterativeChunkedAggregationOperator.BucketedContext makeBucketedContext(int size)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Make a IterativeChunkedAggregationOperator.BucketedContext suitable for this operator if necessary.
  
  Specified by:
  
  makeBucketedContext in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  size - The maximum size of input chunks that will be used with the result context
  
  Returns:
  
  A new IterativeChunkedAggregationOperator.BucketedContext, or null if none is necessary
- makeSingletonContext
  
  public IterativeChunkedAggregationOperator.SingletonContext makeSingletonContext(int size)
  
  Description copied from interface: IterativeChunkedAggregationOperator
  
  Make a IterativeChunkedAggregationOperator.SingletonContext suitable for this operator if necessary.
  
  Specified by:
  
  makeSingletonContext in interface IterativeChunkedAggregationOperator
  
  Parameters:
  
  size - The maximum size of input chunks that will be used with the result context
  
  Returns:
  
  A new IterativeChunkedAggregationOperator.SingletonContext, or null if none is necessary
- makeSecondaryOperator
  
  public IterativeChunkedAggregationOperator makeSecondaryOperator(boolean isMinimum, String resultName)

Class SsmChunkedMinMaxOperator

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

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Details

Method Details