Package io.deephaven.extensions.barrage.chunk

Class ChunkInputStreamGenerator.DrainableColumn

java.lang.Object

java.io.InputStream

io.deephaven.extensions.barrage.util.DefensiveDrainable

io.deephaven.extensions.barrage.chunk.ChunkInputStreamGenerator.DrainableColumn

All Implemented Interfaces:

io.grpc.Drainable, Closeable, AutoCloseable

Direct Known Subclasses:

SingleElementListHeaderInputStreamGenerator

Enclosing interface:

ChunkInputStreamGenerator

public abstract static class ChunkInputStreamGenerator.DrainableColumn
extends DefensiveDrainable

Constructor Summary

Constructors

Constructor	Description
DrainableColumn()

Method Summary

Modifier and Type	Method	Description
abstract int	nullCount()	Count the number of null elements in the outer-most layer of this column (i.e.
abstract void	visitBuffers(ChunkInputStreamGenerator.BufferListener listener)	Append the buffer boundaries to the flatbuffer payload via the supplied listener.
abstract void	visitFieldNodes(ChunkInputStreamGenerator.FieldNodeListener listener)	Append the field nde to the flatbuffer payload via the supplied listener.

Methods inherited from class io.deephaven.extensions.barrage.util.DefensiveDrainable

available, capture, read, read, read, skip

Methods inherited from class java.io.InputStream

close, mark, markSupported, nullInputStream, readAllBytes, readNBytes, readNBytes, reset, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.grpc.Drainable

drainTo

Constructor Details

DrainableColumn

public DrainableColumn()

Method Details

visitFieldNodes

public abstract void visitFieldNodes(ChunkInputStreamGenerator.FieldNodeListener listener)

Append the field nde to the flatbuffer payload via the supplied listener.

Parameters:

listener - the listener to notify for each logical field node in this payload

visitBuffers

public abstract void visitBuffers(ChunkInputStreamGenerator.BufferListener listener)

Append the buffer boundaries to the flatbuffer payload via the supplied listener.

Parameters:

listener - the listener to notify for each sub-buffer in this payload

nullCount

public abstract int nullCount()

Count the number of null elements in the outer-most layer of this column (i.e. does not count nested nulls inside of arrays)

Returns:

the number of null elements -- 'useDeephavenNulls' counts are always 0 so that we may omit the validity buffer