Package com.illumon.iris.db.v2.updateby.delta

Class BigIntegerDeltaOperator

java.lang.Object

com.illumon.iris.db.v2.updateby.internal.BaseObjectUpdateByOperator<BigInteger>

com.illumon.iris.db.v2.updateby.delta.BigIntegerDeltaOperator

All Implemented Interfaces:

UpdateByOperator

public class BigIntegerDeltaOperator
extends BaseObjectUpdateByOperator<BigInteger>

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.updateby.internal.BaseObjectUpdateByOperator

BaseObjectUpdateByOperator.Context

Nested classes/interfaces inherited from interface com.illumon.iris.db.v2.updateby.UpdateByOperator

UpdateByOperator.UpdateContext

Field Summary

Fields inherited from class com.illumon.iris.db.v2.updateby.internal.BaseObjectUpdateByOperator

affectingColumns, bucketLastVal, initialized, isRedirected, maybeInnerSource, outputSource, pair, singletonGroup, singletonVal

Fields inherited from interface com.illumon.iris.db.v2.updateby.UpdateByOperator

ZERO_LENGTH_OP_ARRAY

Constructor Summary

Constructors

Constructor	Description
BigIntegerDeltaOperator(MatchPair pair, RedirectionIndex redirectionIndex, DeltaControl control)

Method Summary

Modifier and Type	Method	Description
protected void	accumulate(ObjectChunk<BigInteger,Attributes.Values> asObjects, BaseObjectUpdateByOperator<BigInteger>.Context ctx, int runStart, int runLength)
void	addChunk(UpdateByOperator.UpdateContext context, Chunk<Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> keyChunk, IntChunk<Attributes.KeyIndices> bucketPositions, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> runLengths)	Add a chunk of bucketed items to the operation.
protected void	doAddChunk(BaseObjectUpdateByOperator<BigInteger>.Context ctx, OrderedKeys inputKeys, Chunk<Attributes.Values> workingChunk, long groupPosition)	Add a chunk of values to the operator.
void	resetForReprocess(UpdateByOperator.UpdateContext context, ReadOnlyIndex sourceIndex, ColumnSource<?> inputSource, long firstUnmodifiedKey)	Reset the operator to the state at the `firstModifiedKey` for non-bucketed operation.
void	resetForReprocess(UpdateByOperator.UpdateContext ctx, ReadOnlyIndex bucketIndex, ColumnSource<?> inputSource, long bucketPosition, long firstUnmodifiedKey)	Reset the operator to the state at the `firstModifiedKey` for the specified bucket.

Methods inherited from class com.illumon.iris.db.v2.updateby.internal.BaseObjectUpdateByOperator

addChunk, anyModified, applyOutputShift, applyShift, canProcessNormalUpdate, finishFor, getAdditionalModifications, getAffectingColumnNames, getInputColumnName, getOutputColumnNames, getOutputColumns, initializeFor, initializeForUpdate, makeUpdateContext, modifyChunk, onBucketsRemoved, removeChunk, reprocessChunk, reprocessChunk, requiresKeys, requiresValues, setBucketCapacity, setChunkSize, startTrackingPrev

Methods inherited from class java.lang.Object

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

Constructor Details

BigIntegerDeltaOperator

public BigIntegerDeltaOperator(@NotNull
 MatchPair pair,
 @Nullable
 RedirectionIndex redirectionIndex,
 @NotNull
 DeltaControl control)

Method Details

resetForReprocess

public void resetForReprocess(@NotNull
 UpdateByOperator.UpdateContext context,
 @NotNull
 ReadOnlyIndex sourceIndex,
 @NotNull
 ColumnSource<?> inputSource,
 long firstUnmodifiedKey)

Description copied from interface: UpdateByOperator

Reset the operator to the state at the `firstModifiedKey` for non-bucketed operation. This is invoked immediately prior to calls to UpdateByOperator.reprocessChunk(UpdateContext, OrderedKeys, LongChunk, Chunk, ReadOnlyIndex).

A `firstUnmodifiedKey` of ReadOnlyIndex.NULL_KEY indicates that the entire table needs to be recomputed.

Specified by:

resetForReprocess in interface UpdateByOperator

Overrides:

resetForReprocess in class BaseObjectUpdateByOperator<BigInteger>

Parameters:

context - the context object

sourceIndex - the current index of the source table

inputSource - the most primitive form of the input column source

firstUnmodifiedKey - the first unmodified key after which we will reprocess rows.

resetForReprocess

public void resetForReprocess(@NotNull
 UpdateByOperator.UpdateContext ctx,
 @NotNull
 ReadOnlyIndex bucketIndex,
 @NotNull
 ColumnSource<?> inputSource,
 long bucketPosition,
 long firstUnmodifiedKey)

Description copied from interface: UpdateByOperator

Reset the operator to the state at the `firstModifiedKey` for the specified bucket. This is invoked immediately prior to calls to UpdateByOperator.reprocessChunk(UpdateContext, OrderedKeys, Chunk, LongChunk, IntChunk, IntChunk, IntChunk).

Specified by:

resetForReprocess in interface UpdateByOperator

Overrides:

resetForReprocess in class BaseObjectUpdateByOperator<BigInteger>

Parameters:

ctx - the context object

bucketIndex - the current index of the specified bucket

inputSource - the most primitive form of the input column source

firstUnmodifiedKey - the first unmodified key in the bucket after which we will reprocess rows.

addChunk

public void addChunk(@NotNull
 UpdateByOperator.UpdateContext context,
 @NotNull
 Chunk<Attributes.Values> values,
 @NotNull
 LongChunk<? extends Attributes.KeyIndices> keyChunk,
 @NotNull
 IntChunk<Attributes.KeyIndices> bucketPositions,
 @NotNull
 IntChunk<Attributes.ChunkPositions> startPositions,
 @NotNull
 IntChunk<Attributes.ChunkLengths> runLengths)

Description copied from interface: UpdateByOperator

Add a chunk of bucketed items to the operation.

Parameters:

context - the context object

values - the value chunk

keyChunk - a chunk of keys for the rows being added

bucketPositions - a chunk of hash bucket positions for each key

startPositions - the start position of a run within the chunk

runLengths - the runLengths of each run of bucket values

doAddChunk

protected void doAddChunk(@NotNull
 BaseObjectUpdateByOperator<BigInteger>.Context ctx,
 @NotNull
 OrderedKeys inputKeys,
 @NotNull
 Chunk<Attributes.Values> workingChunk,
 long groupPosition)

Description copied from class: BaseObjectUpdateByOperator

Add a chunk of values to the operator.

Specified by:

doAddChunk in class BaseObjectUpdateByOperator<BigInteger>

Parameters:

ctx - the context object

inputKeys - the input keys for the chunk

workingChunk - the chunk of values

groupPosition - the bucket position that the values belong to.

accumulate

protected void accumulate(@NotNull
 ObjectChunk<BigInteger,Attributes.Values> asObjects,
 @NotNull
 BaseObjectUpdateByOperator<BigInteger>.Context ctx,
 int runStart,
 int runLength)