Package io.deephaven.extensions.barrage.chunk

Class BaseChunkInputStreamGenerator<T extends Chunk<Values>>

java.lang.Object

io.deephaven.extensions.barrage.chunk.BaseChunkInputStreamGenerator<T>

All Implemented Interfaces:

ChunkInputStreamGenerator, SafeCloseable, AutoCloseable

Direct Known Subclasses:

BooleanChunkInputStreamGenerator, ByteChunkInputStreamGenerator, CharChunkInputStreamGenerator, DoubleChunkInputStreamGenerator, FloatChunkInputStreamGenerator, IntChunkInputStreamGenerator, LongChunkInputStreamGenerator, ShortChunkInputStreamGenerator, VarBinaryChunkInputStreamGenerator, VarListChunkInputStreamGenerator, VectorChunkInputStreamGenerator

public abstract class BaseChunkInputStreamGenerator<T extends Chunk<Values>>
extends Object
implements ChunkInputStreamGenerator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final class	BaseChunkInputStreamGenerator.SerContext

Nested classes/interfaces inherited from interface io.deephaven.extensions.barrage.chunk.ChunkInputStreamGenerator

ChunkInputStreamGenerator.BufferInfo, ChunkInputStreamGenerator.BufferListener, ChunkInputStreamGenerator.DrainableColumn, ChunkInputStreamGenerator.FieldNodeInfo, ChunkInputStreamGenerator.FieldNodeListener

Field Summary

Fields

Modifier and Type	Field	Description
protected final T	chunk
protected final int	elementSize
static final byte[]	PADDING_BUFFER
protected static final AtomicIntegerFieldUpdater<BaseChunkInputStreamGenerator>	REFERENCE_COUNT_UPDATER
static final int	REMAINDER_MOD_8_MASK

Method Summary

Modifier and Type	Method	Description
void	close()
long	getLastRowOffset()	Returns the offset of the final row this generator can produce.
protected static int	getNumLongsForBitPackOfSize(int numElements)	Returns the number of longs needed to represent a single bit per element.
long	getRowOffset()	Returns the number of rows that were sent before the first row in this generator.
protected static int	getValidityMapSerializationSizeFor(int numElements)	Returns expected size of validity map in bytes.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.extensions.barrage.chunk.ChunkInputStreamGenerator

getInputStream

Field Details

PADDING_BUFFER

public static final byte[] PADDING_BUFFER

REMAINDER_MOD_8_MASK

public static final int REMAINDER_MOD_8_MASK

See Also:

• Constant Field Values

REFERENCE_COUNT_UPDATER

protected static final AtomicIntegerFieldUpdater<BaseChunkInputStreamGenerator> REFERENCE_COUNT_UPDATER

chunk

protected final T extends Chunk<Values> chunk

elementSize

protected final int elementSize

Method Details

getRowOffset

public long getRowOffset()

Description copied from interface: ChunkInputStreamGenerator

Returns the number of rows that were sent before the first row in this generator.

Specified by:

getRowOffset in interface ChunkInputStreamGenerator

getLastRowOffset

public long getLastRowOffset()

Description copied from interface: ChunkInputStreamGenerator

Returns the offset of the final row this generator can produce.

Specified by:

getLastRowOffset in interface ChunkInputStreamGenerator

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

getValidityMapSerializationSizeFor

protected static int getValidityMapSerializationSizeFor(int numElements)

Returns expected size of validity map in bytes.

Parameters:

numElements - the number of rows

Returns:

number of bytes to represent the validity buffer for numElements

getNumLongsForBitPackOfSize

protected static int getNumLongsForBitPackOfSize(int numElements)

Returns the number of longs needed to represent a single bit per element.

Parameters:

numElements - the number of rows

Returns:

number of longs needed to represent numElements bits rounded up to the nearest long