Package io.deephaven.engine.table

Interface ChunkSink<ATTR extends Any>

All Superinterfaces:

ChunkSource<ATTR>, FillContextMaker, GetContextMaker

All Known Subinterfaces:

WritableColumnSource<T>, WritableRowRedirection

All Known Implementing Classes:

ArrayBackedColumnSource, BooleanArraySource, BooleanSingleValueSource, BooleanSparseArraySource, BooleanSparseArraySource.ReinterpretedAsByte, ByteArraySource, ByteSingleValueSource, ByteSparseArraySource, CharacterArraySource, CharacterSingleValueSource, CharacterSparseArraySource, ContiguousWritableRowRedirection, DeltaAwareColumnSource, DoubleArraySource, DoubleSingleValueSource, DoubleSparseArraySource, FloatArraySource, FloatSingleValueSource, FloatSparseArraySource, GroupedWritableRowRedirection, Immutable2DByteArraySource, Immutable2DCharArraySource, Immutable2DDoubleArraySource, Immutable2DFloatArraySource, Immutable2DInstantArraySource, Immutable2DIntArraySource, Immutable2DLongArraySource, Immutable2DNanosBasedTimeArraySource, Immutable2DObjectArraySource, Immutable2DShortArraySource, Immutable2DZonedDateTimeArraySource, ImmutableByteArraySource, ImmutableCharArraySource, ImmutableDoubleArraySource, ImmutableFloatArraySource, ImmutableInstantArraySource, ImmutableIntArraySource, ImmutableLongArraySource, ImmutableNanosBasedTimeArraySource, ImmutableObjectArraySource, ImmutableShortArraySource, ImmutableZonedDateTimeArraySource, InstantArraySource, InstantSparseArraySource, IntColumnSourceWritableRowRedirection, IntegerArraySource, IntegerSingleValueSource, IntegerSparseArraySource, LongArraySource, LongColumnSourceWritableRowRedirection, LongSingleValueSource, LongSparseArraySource, NanosBasedTimeArraySource, NanosBasedTimeSparseArraySource, NullValueColumnSource, ObjectArraySource, ObjectSingleValueSource, ObjectSparseArraySource, ShortArraySource, ShortSingleValueSource, ShortSparseArraySource, SingleValueColumnSource, SparseArrayColumnSource, WritableByteAsBooleanColumnSource, WritableRedirectedColumnSource, WritableRowRedirectionLockFree, ZonedDateTimeArraySource, ZonedDateTimeSparseArraySource

public interface ChunkSink<ATTR extends Any>
extends ChunkSource<ATTR>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ChunkSink.FillFromContext

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

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

Field Summary

Fields

Modifier and Type	Field	Description
static final ChunkSink.FillFromContext	DEFAULT_FILL_FROM_INSTANCE

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

DEFAULT_FILL_INSTANCE, ZERO_LENGTH_CHUNK_SOURCE_ARRAY

Method Summary

Modifier and Type	Method	Description
void	fillFromChunk(@NotNull ChunkSink.FillFromContext context, @NotNull Chunk<? extends ATTR> src, @NotNull RowSequence rowSequence)	Fills the ChunkSink with data from the source, with data corresponding to the keys from the given RowSequence.
void	fillFromChunkUnordered(@NotNull ChunkSink.FillFromContext context, @NotNull Chunk<? extends ATTR> src, @NotNull LongChunk<RowKeys> keys)	Fills the ChunkSink with data from the source, with data corresponding to the keys from the given key chunk.
default ChunkSink.FillFromContext	makeFillFromContext(int chunkCapacity)	Make a context suitable for the fillFromChunk(io.deephaven.engine.table.ChunkSink.FillFromContext, io.deephaven.chunk.Chunk<? extends ATTR>, io.deephaven.engine.rowset.RowSequence) method.

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

fillChunk, getChunk, getChunk, getChunkType

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

makeFillContext, makeFillContext

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

makeGetContext, makeGetContext

Field Details

DEFAULT_FILL_FROM_INSTANCE

static final ChunkSink.FillFromContext DEFAULT_FILL_FROM_INSTANCE

Method Details

makeFillFromContext

default ChunkSink.FillFromContext makeFillFromContext(int chunkCapacity)

Make a context suitable for the fillFromChunk(io.deephaven.engine.table.ChunkSink.FillFromContext, io.deephaven.chunk.Chunk<? extends ATTR>, io.deephaven.engine.rowset.RowSequence) method.

fillFromChunk

void fillFromChunk(@NotNull
 @NotNull ChunkSink.FillFromContext context,
 @NotNull
 @NotNull Chunk<? extends ATTR> src,
 @NotNull
 @NotNull RowSequence rowSequence)

Fills the ChunkSink with data from the source, with data corresponding to the keys from the given RowSequence.

Parameters:

context - A context containing all mutable/state related data used in writing the Chunk.

src - The source of the data rowSequence

rowSequence - An RowSequence representing the keys to be written

fillFromChunkUnordered

void fillFromChunkUnordered(@NotNull
 @NotNull ChunkSink.FillFromContext context,
 @NotNull
 @NotNull Chunk<? extends ATTR> src,
 @NotNull
 @NotNull LongChunk<RowKeys> keys)

Fills the ChunkSink with data from the source, with data corresponding to the keys from the given key chunk.

Parameters:

context - A context containing all mutable/state related data used in writing the Chunk.

src - The source of the data RowSequence

keys - A LongChunk representing the keys to be written