Package io.deephaven.extensions.barrage.chunk

Class SingleElementListHeaderInputStreamGenerator

java.lang.Object

java.io.InputStream

io.deephaven.extensions.barrage.util.DefensiveDrainable

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

io.deephaven.extensions.barrage.chunk.SingleElementListHeaderInputStreamGenerator

All Implemented Interfaces:

io.grpc.Drainable, Closeable, AutoCloseable

public class SingleElementListHeaderInputStreamGenerator
extends ChunkInputStreamGenerator.DrainableColumn

This helper class is used to generate only the header of an arrow list that contains a single element.

Constructor Summary

Constructors

Constructor	Description
SingleElementListHeaderInputStreamGenerator(int numElements)

Method Summary

Modifier and Type	Method	Description
int	available()	A defensive drainable needs to override available.
int	drainTo(OutputStream outputStream)
int	nullCount()	Count the number of null elements in the outer-most layer of this column (i.e.
void	visitBuffers(ChunkInputStreamGenerator.BufferListener listener)	Append the buffer boundaries to the flatbuffer payload via the supplied listener.
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

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

Constructor Details

SingleElementListHeaderInputStreamGenerator

public SingleElementListHeaderInputStreamGenerator(int numElements)

Method Details

visitFieldNodes

public void visitFieldNodes(ChunkInputStreamGenerator.FieldNodeListener listener)

Description copied from class: ChunkInputStreamGenerator.DrainableColumn

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

Specified by:

visitFieldNodes in class ChunkInputStreamGenerator.DrainableColumn

Parameters:

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

visitBuffers

public void visitBuffers(ChunkInputStreamGenerator.BufferListener listener)

Description copied from class: ChunkInputStreamGenerator.DrainableColumn

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

Specified by:

visitBuffers in class ChunkInputStreamGenerator.DrainableColumn

Parameters:

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

nullCount

public int nullCount()

Description copied from class: ChunkInputStreamGenerator.DrainableColumn

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

Specified by:

nullCount in class ChunkInputStreamGenerator.DrainableColumn

Returns:

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

drainTo

public int drainTo(OutputStream outputStream)
            throws IOException

Throws:

IOException

available

public int available()
              throws IOException

Description copied from class: DefensiveDrainable

A defensive drainable needs to override available. As opposed to the generic InputStream, this method must return the exact amount available.

Overrides:

available in class DefensiveDrainable

Returns:

the exact amount available

Throws:

IOException - if an I/O exception occurs