com.illumon.iris.db.v2.by.ShortChunkedSumOperator

All Implemented Interfaces:: IterativeChunkedAggregationOperator, ChunkSource<Attributes.Values>, FillContextMaker, GetContextMaker

public class ShortChunkedSumOperator
extends Object
implements IterativeChunkedAggregationOperator, ChunkSource<Attributes.Values>

Iterative sum operator, extended for absolute values and regular sums.

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource
ChunkSource.FillContext, ChunkSource.GetContext, ChunkSource.WithPrev<ATTR extends Attributes.Any>

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.sources.chunk.ChunkSource
DEFAULT_FILL_INSTANCE, ZERO_LENGTH_CHUNK_SOURCE_ARRAY

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.
`void`	`fillChunk(ChunkSource.FillContext context, WritableChunk<? super Attributes.Values> destination, OrderedKeys orderedKeys)`	Populates the given destination chunk with data corresponding to the keys from the given `OrderedKeys`.
`Chunk<? extends Attributes.Values>`	`getChunk(ChunkSource.GetContext context, long firstKey, long lastKey)`	Same as `ChunkSource.getChunk(GetContext, OrderedKeys)`, except that you pass in the begin and last keys representing the begin and last (inclusive) keys of a single range rather than an `OrderedKeys`.
`Chunk<? extends Attributes.Values>`	`getChunk(ChunkSource.GetContext context, OrderedKeys orderedKeys)`	Returns a chunk of data corresponding to the keys from the given `OrderedKeys`.
`Class<?>`	`getNativeType()`
`Map<String,? extends ColumnSource<?>>`	`getResultColumns()`	Return a map of result columns produced by this operator.
`ChunkSource.FillContext`	`makeFillContext(int chunkCapacity, SharedContext sharedContext)`	Allocate a new `ChunkSource.FillContext` for filling chunks from this `FillContextMaker`, typically a `ChunkSource`.
`ChunkSource.GetContext`	`makeGetContext(int chunkCapacity, SharedContext sharedContext)`	Allocate a new `ChunkSource.GetContext` for retrieving chunks from this `GetContextMaker`, typically a `ChunkSource`.
`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.sources.chunk.ChunkSource

getChunkType

Methods inherited from interface com.illumon.iris.db.v2.sources.chunk.FillContextMaker

makeFillContext

Methods inherited from interface com.illumon.iris.db.v2.sources.chunk.GetContextMaker

makeGetContext

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
- 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 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
- 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
- getNativeType
  
  public Class<?> getNativeType()
  
  Specified by:
  
  getNativeType in interface ChunkSource<Attributes.Values>
- getChunk
  
  public Chunk<? extends Attributes.Values> getChunk(@NotNull ChunkSource.GetContext context, @NotNull OrderedKeys orderedKeys)
  
  Description copied from interface: ChunkSource
  
  Returns a chunk of data corresponding to the keys from the given OrderedKeys.
  
  Specified by:
  
  getChunk in interface ChunkSource<Attributes.Values>
  
  Parameters:
  
  context - A context containing all mutable/state related data used in retrieving the Chunk. In particular, the Context may be used to provide a Chunk data pool
  
  orderedKeys - An OrderedKeys representing the keys to be fetched
  
  Returns:
  
  A chunk of data corresponding to the keys from the given OrderedKeys
- getChunk
  
  public Chunk<? extends Attributes.Values> getChunk(@NotNull ChunkSource.GetContext context, long firstKey, long lastKey)
  
  Description copied from interface: ChunkSource
  
  Same as ChunkSource.getChunk(GetContext, OrderedKeys), except that you pass in the begin and last keys representing the begin and last (inclusive) keys of a single range rather than an OrderedKeys. Typically you want to call this only if you don't have an OrderedKeys, such as during an OrderedKeys.forAllLongRanges(LongRangeConsumer) call. In this case, it allows you to avoid creating an intermediary OrderedKeys object.
  
  Specified by:
  
  getChunk in interface ChunkSource<Attributes.Values>
  
  Parameters:
  
  context - A context containing all mutable/state related data used in retrieving the Chunk. In particular, the Context may be used to provide a Chunk data pool
  
  firstKey - The beginning key (inclusive) of the range to fetch in the chunk
  
  lastKey - The last key (inclusive) of the range to fetch in the chunk
  
  Returns:
  
  A chunk of data corresponding to the keys from the given range.
- fillChunk
  
  public void fillChunk(@NotNull ChunkSource.FillContext context, @NotNull WritableChunk<? super Attributes.Values> destination, @NotNull OrderedKeys orderedKeys)
  
  Description copied from interface: ChunkSource
  
  Populates the given destination chunk with data corresponding to the keys from the given OrderedKeys.
  
  Specified by:
  
  fillChunk in interface ChunkSource<Attributes.Values>
  
  Parameters:
  
  context - A context containing all mutable/state related data used in retrieving the Chunk.
  
  destination - The chunk to be populated according to orderedKeys. No assumptions shall be made about the size of the chunk shall be made. The chunk will be populated from position [0,orderedKeys.size()).
  
  orderedKeys - An OrderedKeys representing the keys to be fetched
- makeFillContext
  
  public ChunkSource.FillContext makeFillContext(int chunkCapacity, SharedContext sharedContext)
  
  Description copied from interface: FillContextMaker
  
  Allocate a new ChunkSource.FillContext for filling chunks from this FillContextMaker, typically a ChunkSource.
  
  Specified by:
  
  makeFillContext in interface FillContextMaker
  
  Parameters:
  
  chunkCapacity - The maximum size of any WritableChunk that will be filled with this context
  
  sharedContext - Shared store of intermediate results.
  
  Returns:
  
  A context for use with fill operations
- makeGetContext
  
  public ChunkSource.GetContext makeGetContext(int chunkCapacity, SharedContext sharedContext)
  
  Description copied from interface: GetContextMaker
  
  Allocate a new ChunkSource.GetContext for retrieving chunks from this GetContextMaker, typically a ChunkSource.
  
  Specified by:
  
  makeGetContext in interface GetContextMaker
  
  Parameters:
  
  chunkCapacity - The maximum size required for any WritableChunk allocated as part of the result.
  
  sharedContext - Shared store of intermediate results.
  
  Returns:
  
  A context for use with get operations

Class ShortChunkedSumOperator

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource

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

Field Summary

Fields inherited from interface com.illumon.iris.db.v2.sources.chunk.ChunkSource