Package io.deephaven.extensions.barrage.chunk

Interface ChunkReader.Factory

All Known Implementing Classes:
DefaultChunkReaderFactory
Enclosing interface:
ChunkReader<READ_CHUNK_TYPE extends WritableChunk<Values>>
public static interface ChunkReader.Factory
Supports creation of ChunkReader instances to use when processing a flight stream. JVM implementations for client and server should probably use DefaultChunkReaderFactory.INSTANCE.

  • Method Details

    • newReader

      <T extends WritableChunk<Values>> ChunkReader<T> newReader(@NotNull @NotNull BarrageTypeInfo<org.apache.arrow.flatbuf.Field> typeInfo, @NotNull @NotNull BarrageOptions options)
      Returns a ChunkReader for the specified arguments.
      Parameters:
      typeInfo - the type of data to read into a chunk
      options - options for reading the stream
      Returns:
      a ChunkReader based on the given options, factory, and type to read