Package io.deephaven.extensions.barrage

Class ColumnChunksWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>

java.lang.Object

io.deephaven.extensions.barrage.ColumnChunksWriter<SOURCE_CHUNK_TYPE>

All Implemented Interfaces:

SafeCloseable, AutoCloseable

public class ColumnChunksWriter<SOURCE_CHUNK_TYPE extends Chunk<Values>>
extends Object
implements SafeCloseable

Constructor Summary

Constructors

Constructor	Description
ColumnChunksWriter(ChunkWriter<SOURCE_CHUNK_TYPE> writer, List<SOURCE_CHUNK_TYPE> chunks)

Method Summary

Modifier and Type	Method	Description
ChunkWriter.Context[]	chunks()
void	close()
ChunkWriter.DrainableColumn	empty(@NotNull BarrageOptions options)
ChunkWriter.DrainableColumn	empty(@NotNull BarrageOptions options, @Nullable DictionaryWriterRegistry dictionaryRegistry)	Like empty(BarrageOptions), but threads dictionaryRegistry down to a dictionary-encoded writer nested within this column's writer (e.g.
ChunkWriter<SOURCE_CHUNK_TYPE>	writer()

Methods inherited from class java.lang.Object

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

Constructor Details

ColumnChunksWriter

public ColumnChunksWriter(ChunkWriter<SOURCE_CHUNK_TYPE> writer,
 List<SOURCE_CHUNK_TYPE> chunks)

Method Details

writer

public ChunkWriter<SOURCE_CHUNK_TYPE> writer()

chunks

public ChunkWriter.Context[] chunks()

empty

public ChunkWriter.DrainableColumn empty(@NotNull
 @NotNull BarrageOptions options)
                                  throws IOException

Throws:

IOException

empty

public ChunkWriter.DrainableColumn empty(@NotNull
 @NotNull BarrageOptions options,
 @Nullable
 @Nullable DictionaryWriterRegistry dictionaryRegistry)
                                  throws IOException

Like empty(BarrageOptions), but threads dictionaryRegistry down to a dictionary-encoded writer nested within this column's writer (e.g. the values child of a run-end-encoded column), so it still registers its state -- and emits its initial isDelta=false DictionaryBatch -- even when this column's very first batch carries no rows.

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable