Package io.deephaven.extensions.barrage.chunk
package io.deephaven.extensions.barrage.chunk
-
ClassDescriptionTyped kernel for copying individual cells from per-delta source chunks into a destination chunk, using a pre-computed encoded mapping array.Base context for a BarrageCopyKernel.Typed kernel for single-pass run detection over a row subset, used by
RunEndEncodedChunkWriter.BaseChunkReader.ChunkTransformer<READ_CHUNK_TYPE extends Chunk<Values>,DEST_CHUNK_TYPE extends WritableChunk<Values>> TheChunkReaderinterface provides a mechanism for consuming Flight/Barrage streams and transforming them intoWritableChunkinstances for further processing.Supports creation ofChunkReaderinstances to use when processing a flight stream.TheChunkWriterinterface provides a mechanism for writing chunks of data into a structured format suitable for transmission in Apache Arrow's columnar format.Creator ofChunkWriterinstances.JVM implementation ofChunkReader.Factory, suitable for use in Java clients and servers.Factory method to create a newChunkReaderfor the given type and options.JVM implementation ofChunkWriter.Factory, suitable for use in Java clients and servers.This supplier interface simplifies the cost to operate off of the ArrowType directly since the Arrow POJO is not yet supported over GWT.Reads an Arrow Dictionary-Encoded column from the wire into a flat Deephaven chunk.Serializes a flat column chunk as Arrow Dictionary Encoded on the wire.Per-stream registry that maps Arrow dictionary ids to their decoded value chunks.Manages the set ofDictionaryWriterStateinstances for a single barrage stream (snapshot or subscription update sequence), one per Arrow dictionary id.Per-id state plus the values writer needed to serialize dictionary values into a DictionaryBatch.The server-sideDictionaryWriterRegistryimplementation, backed by fastutil maps.Tracks the cumulative dictionary for one Arrow dictionary id within a barrage stream.TheExpansionKernelinterface provides methods for transforming chunks containing complex or nested data structures into flattened representations, and vice versa.ListChunkWriter<LIST_TYPE,COMPONENT_CHUNK_TYPE extends Chunk<Values>> DictionaryWriterStateimplementation for viewport subscriptions and snapshots.AChunkWriterimplementation that writes an Apache Arrow Null Column; which only writes a field node.Reads an Arrow Run-End Encoded (REE) column from the wire into a flat Deephaven chunk.Serializes a flat column chunk as Arrow Run-End Encoded (REE) on the wire.Per-subscriberDictionaryWriterStatefor full subscriptions (and growing subscriptions targeting a full subscription).Shared per-table dictionary state for full subscriptions.TheSingleElementListHeaderReaderis a specializedBaseChunkReaderused to handle singleton list-wrapped columns in Apache Arrow record batches.TheSingleElementListHeaderWriteris a specializedChunkWriter.DrainableColumnimplementation that writes the header for singleton list-wrapped columns in Apache Arrow record batches.TransformingChunkReader<INPUT_CHUNK_TYPE extends WritableChunk<Values>,OUTPUT_CHUNK_TYPE extends WritableChunk<Values>> AChunkReaderthat reads a chunk of wire values and transforms them into a different chunk type.