Package io.deephaven.engine.table.impl.util

Class GroupedWritableRowRedirection

java.lang.Object

io.deephaven.engine.table.impl.util.GroupedWritableRowRedirection

All Implemented Interfaces:

ChunkSink<RowKeys>, ChunkSource<RowKeys>, ChunkSource.WithPrev<RowKeys>, FillContextMaker, GetContextMaker, DefaultChunkSource<RowKeys>, DefaultChunkSource.WithPrev<RowKeys>, FillUnordered<RowKeys>, RowRedirection, WritableRowRedirection

public class GroupedWritableRowRedirection
extends Object
implements WritableRowRedirection

The GroupedWritableRowRedirection is intended for situations where you have several row sets that represent contiguous rows of your output table and a flat output RowSet.

When sorting a table by indexed columns, instead of using a large contiguous WritableRowRedirection, we simply store the row sets for each group and the accumulated cardinality. We then binary search in the accumulated cardinality for a given key; and fetch the corresponding offset from that group's row set.

This WritableRowRedirection does not support mutation.

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.engine.table.ChunkSink

ChunkSink.FillFromContext

Nested classes/interfaces inherited from interface io.deephaven.engine.table.ChunkSource

ChunkSource.FillContext, ChunkSource.GetContext, ChunkSource.WithPrev<ATTR extends Any>

Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource

DefaultChunkSource.SupportsContiguousGet<ATTR extends Any>, DefaultChunkSource.WithPrev<ATTR extends Any>

Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.util.WritableRowRedirection

WritableRowRedirection.Factory

Field Summary

Fields inherited from interface io.deephaven.engine.table.ChunkSource

DEFAULT_FILL_INSTANCE, ZERO_LENGTH_CHUNK_SOURCE_ARRAY

Fields inherited from interface io.deephaven.engine.table.ChunkSource.WithPrev

ZERO_LENGTH_CHUNK_SOURCE_WITH_PREV_ARRAY

Fields inherited from interface io.deephaven.engine.table.impl.util.WritableRowRedirection

DEFAULT_FILL_FROM_INSTANCE, FACTORY

Constructor Summary

Constructors

Constructor	Description
GroupedWritableRowRedirection(long size, long[] groupSizes, RowSet[] groups)

Method Summary

Modifier and Type	Method	Description
void	fillChunk(@NotNull ChunkSource.FillContext fillContext, @NotNull WritableChunk<? super RowKeys> innerRowKeys, @NotNull RowSequence outerRowKeys)	Lookup each element in a RowSequence and write the result to a WritableLongChunk.
void	fillPrevChunk(@NotNull ChunkSource.FillContext fillContext, @NotNull WritableChunk<? super RowKeys> innerRowKeys, @NotNull RowSequence outerRowKeys)	Lookup each element in a RowSequence using previous values and write the result to a WritableLongChunk.
long	get(long outerRowKey)	Simple redirected lookup.
long	getPrev(long outerRowKey)	Simple redirected lookup, using previous values.
long	put(long outerRowKey, long innerRowKey)	Add or change a mapping from outerRowKey to innerRowKey.
long	remove(long outerRowKey)	Remove a mapping from outerRowKey.
void	startTrackingPrevValues()	Initiate previous value tracking.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource

getChunk, getChunk, getChunkByFilling, makeFillContext, makeGetContext

Methods inherited from interface io.deephaven.engine.table.impl.DefaultChunkSource.WithPrev

getPrevChunk, getPrevChunk, getPrevChunkByFilling, getPrevSource

Methods inherited from interface io.deephaven.engine.table.FillContextMaker

makeFillContext

Methods inherited from interface io.deephaven.engine.table.GetContextMaker

makeGetContext

Methods inherited from interface io.deephaven.engine.table.impl.util.RowRedirection

ascendingMapping, fillChunkUnordered, fillPrevChunkUnordered, getChunkType, isWritable, providesFillUnordered, writableCast

Methods inherited from interface io.deephaven.engine.table.impl.util.WritableRowRedirection

applyShift, fillFromChunk, fillFromChunkUnordered, makeFillFromContext, putVoid, removeAll, removeAllUnordered, removeVoid

Constructor Details

GroupedWritableRowRedirection

public GroupedWritableRowRedirection(long size,
 long[] groupSizes,
 RowSet[] groups)

Method Details

get

public long get(long outerRowKey)

Description copied from interface: RowRedirection

Simple redirected lookup.

Specified by:

get in interface RowRedirection

Parameters:

outerRowKey - The "outer" row key

Returns:

The corresponding "inner" row key, or RowSequence.NULL_ROW_KEY if no mapping exists

getPrev

public long getPrev(long outerRowKey)

Description copied from interface: RowRedirection

Simple redirected lookup, using previous values.

Specified by:

getPrev in interface RowRedirection

Parameters:

outerRowKey - The "outer" row key

Returns:

The corresponding "inner" row key, or RowSequence.NULL_ROW_KEY if no mapping exists

fillChunk

public void fillChunk(@NotNull
 @NotNull ChunkSource.FillContext fillContext,
 @NotNull
 @NotNull WritableChunk<? super RowKeys> innerRowKeys,
 @NotNull
 @NotNull RowSequence outerRowKeys)

Description copied from interface: RowRedirection

Lookup each element in a RowSequence and write the result to a WritableLongChunk.

Specified by:

fillChunk in interface ChunkSource<RowKeys>

Specified by:

fillChunk in interface RowRedirection

Parameters:

fillContext - The fill context

innerRowKeys - The result WritableLongChunk

outerRowKeys - The row keys to lookup in this RowRedirection

fillPrevChunk

public void fillPrevChunk(@NotNull
 @NotNull ChunkSource.FillContext fillContext,
 @NotNull
 @NotNull WritableChunk<? super RowKeys> innerRowKeys,
 @NotNull
 @NotNull RowSequence outerRowKeys)

Description copied from interface: RowRedirection

Lookup each element in a RowSequence using previous values and write the result to a WritableLongChunk.

Specified by:

fillPrevChunk in interface ChunkSource.WithPrev<RowKeys>

Specified by:

fillPrevChunk in interface RowRedirection

Parameters:

fillContext - The fill context

innerRowKeys - The result WritableLongChunk

outerRowKeys - The row keys to lookup in this RowRedirection

remove

public long remove(long outerRowKey)

Description copied from interface: WritableRowRedirection

Remove a mapping from outerRowKey.

Specified by:

remove in interface WritableRowRedirection

Parameters:

outerRowKey - The outer row key to unmap

Returns:

The inner row key previously mapped from outerRowKey, or RowSequence.NULL_ROW_KEY if there was no mapping

put

public long put(long outerRowKey,
 long innerRowKey)

Description copied from interface: WritableRowRedirection

Add or change a mapping from outerRowKey to innerRowKey.

Specified by:

put in interface WritableRowRedirection

Parameters:

outerRowKey - The outer row key to map from

innerRowKey - The inner row key to map to

Returns:

The inner row key previously mapped from outerRowKey, or RowSequence.NULL_ROW_KEY if there was no mapping

startTrackingPrevValues

public void startTrackingPrevValues()

Description copied from interface: WritableRowRedirection

Initiate previous value tracking.

Specified by:

startTrackingPrevValues in interface WritableRowRedirection