Package io.deephaven.extensions.barrage

Class BarrageStreamGeneratorImpl.RowSetGenerator

java.lang.Object

io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.ByteArrayGenerator

io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.RowSetGenerator

All Implemented Interfaces:

SafeCloseable, AutoCloseable

Enclosing class:

BarrageStreamGeneratorImpl

public static class BarrageStreamGeneratorImpl.RowSetGenerator
extends BarrageStreamGeneratorImpl.ByteArrayGenerator
implements SafeCloseable

Field Summary

Fields inherited from class io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.ByteArrayGenerator

len, raw

Constructor Summary

Constructors

Constructor	Description
RowSetGenerator(RowSet rowSet)

Method Summary

Modifier and Type	Method	Description
protected int	addToFlatBuffer(RowSet viewport, com.google.flatbuffers.FlatBufferBuilder builder)	Appends the intersection of the viewport and the originally provided RowSet.
void	close()
DrainableByteArrayInputStream	getInputStream()

Methods inherited from class io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.ByteArrayGenerator

addToFlatBuffer

Methods inherited from class java.lang.Object

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

Constructor Details

RowSetGenerator

public RowSetGenerator(RowSet rowSet)
                throws IOException

Throws:

IOException

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

getInputStream

public DrainableByteArrayInputStream getInputStream()

addToFlatBuffer

protected int addToFlatBuffer(RowSet viewport,
 com.google.flatbuffers.FlatBufferBuilder builder)
                       throws IOException

Appends the intersection of the viewport and the originally provided RowSet.

Parameters:

viewport - the key-space version of the viewport

builder - the flatbuffer builder

Returns:

offset of the item in the flatbuffer

Throws:

IOException