com.illumon.iris.db.v2.by.BooleanChunkedSumOperator

All Implemented Interfaces:: IterativeChunkedAggregationOperator

public final class BooleanChunkedSumOperator
extends Object
implements IterativeChunkedAggregationOperator

Iterative Boolean Sum. Any true value makes the result true. If there are no values, the result is null. All false values result in false.

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 context, 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 context, 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 context, 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 context, 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`	`removeChunk(IterativeChunkedAggregationOperator.BucketedContext context, 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 context, 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, makeBucketedContext, makeSingletonContext, modifyIndices, modifyIndices, propagateFailure, propagateInitialState, propagateUpdates, requiresIndices, resetForStep, shiftChunk, shiftChunk, unchunkedIndex

Method Details
- addChunk
  
  public void addChunk(IterativeChunkedAggregationOperator.BucketedContext context, 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:
  
  context - 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 context, 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:
  
  context - 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 context, 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:
  
  context - 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
- addChunk
  
  public boolean addChunk(IterativeChunkedAggregationOperator.SingletonContext context, 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:
  
  context - 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 context, 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:
  
  context - 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 context, 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:
  
  context - 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
- 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

Class BooleanChunkedSumOperator

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