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

Class LongRecordingUpdateByOperator

java.lang.Object

com.illumon.iris.db.v2.updateby.internal.AbstractStaticUpdateByOperator

com.illumon.iris.db.v2.updateby.internal.LongRecordingUpdateByOperator

All Implemented Interfaces:

ChunkedUpdateByOperator

public class LongRecordingUpdateByOperator
extends AbstractStaticUpdateByOperator

Nested Class Summary

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

ChunkedUpdateByOperator.BucketedUpdateContext, ChunkedUpdateByOperator.UpdateContext

Field Summary

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

ZERO_LENGTH_OP_ARRAY

Constructor Summary

Constructors

Constructor	Description
LongRecordingUpdateByOperator(String inputColumn)

Method Summary

Modifier and Type	Method	Description
void	addChunk(ChunkedUpdateByOperator.BucketedUpdateContext context, Chunk<Attributes.Values> values, LongChunk<? extends Attributes.KeyIndices> keyChunk, IntChunk<Attributes.KeyIndices> bucketPositions, IntChunk<Attributes.ChunkPositions> startPositions, IntChunk<Attributes.ChunkLengths> length)	Add a chunk of bucketed items to the operation.
void	addChunk(ChunkedUpdateByOperator.UpdateContext updateContext, LongChunk<Attributes.OrderedKeyIndices> keyChunk, Chunk<Attributes.Values> workingChunk, long groupPosition)	Add a chunk of non-bucketed items to the operation.
String	getInputColumnName()	Get the name of the input column this operator depends on.
long	getLong(int chunkPosition)
String[]	getOutputColumnNames()	Get an array of the output column names.
Map<String,ColumnSource<?>>	getOutputColumns()	Get a map of outputName to output ColumnSource for this operation.
ChunkedUpdateByOperator.BucketedUpdateContext	makeBucketedContext(int chunkSize)	Make an ChunkedUpdateByOperator.UpdateContext suitable for use with bucketed updates.
ChunkedUpdateByOperator.UpdateContext	makeUpdateContext(int chunkSize)	Make an ChunkedUpdateByOperator.UpdateContext suitable for use with non-bucketed updates.

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

anyModified, anyModified, applyShift, finishFor, finishFor, getAdditionalModifications, initializeFor, initializeFor, modifyChunk, removeChunk, setBucketCapacity, setUpstream, setUpstream, startTrackingPrev

Methods inherited from class java.lang.Object

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

Constructor Details

LongRecordingUpdateByOperator

public LongRecordingUpdateByOperator(@NotNull String inputColumn)

Method Details

getLong

public long getLong(int chunkPosition)

getInputColumnName

@NotNull public String getInputColumnName()

Description copied from interface: ChunkedUpdateByOperator

Get the name of the input column this operator depends on.

Returns:

the name of the input column

getOutputColumnNames

@NotNull public String[] getOutputColumnNames()

Description copied from interface: ChunkedUpdateByOperator

Get an array of the output column names.

Returns:

the output column names.

getOutputColumns

@NotNull public Map<String,ColumnSource<?>> getOutputColumns()

Description copied from interface: ChunkedUpdateByOperator

Get a map of outputName to output ColumnSource for this operation.

Returns:

a map of output column name to output column source

makeUpdateContext

@NotNull public ChunkedUpdateByOperator.UpdateContext makeUpdateContext(int chunkSize)

Description copied from interface: ChunkedUpdateByOperator

Make an ChunkedUpdateByOperator.UpdateContext suitable for use with non-bucketed updates.

Parameters:

chunkSize - The expected size of chunks that will be provided during the update,

Returns:

a new updateContext

makeBucketedContext

@NotNull public ChunkedUpdateByOperator.BucketedUpdateContext makeBucketedContext(int chunkSize)

Description copied from interface: ChunkedUpdateByOperator

Make an ChunkedUpdateByOperator.UpdateContext suitable for use with bucketed updates.

Parameters:

chunkSize - The expected size of chunks that will be provided during the update,

Returns:

a new updateContext

addChunk

public void addChunk(@NotNull ChunkedUpdateByOperator.UpdateContext updateContext, @NotNull LongChunk<Attributes.OrderedKeyIndices> keyChunk, @NotNull Chunk<Attributes.Values> workingChunk, long groupPosition)

Description copied from interface: ChunkedUpdateByOperator

Add a chunk of non-bucketed items to the operation.

Parameters:

updateContext - the context object

keyChunk - a chunk of keys for the rows being added

workingChunk - the chunk of values for the rows being added

groupPosition - the group position

addChunk

public void addChunk(@NotNull ChunkedUpdateByOperator.BucketedUpdateContext 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> length)

Description copied from interface: ChunkedUpdateByOperator

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

length - the length of each run of bucket values