Package io.deephaven.extensions.barrage

Class BarrageMessageWriterImpl.RowSetWriter

java.lang.Object

io.deephaven.extensions.barrage.BarrageMessageWriterImpl.ByteArrayWriter

io.deephaven.extensions.barrage.BarrageMessageWriterImpl.RowSetWriter

All Implemented Interfaces:

SafeCloseable, AutoCloseable

Enclosing class:

BarrageMessageWriterImpl

public static class BarrageMessageWriterImpl.RowSetWriter
extends BarrageMessageWriterImpl.ByteArrayWriter
implements SafeCloseable

Field Summary

Fields inherited from class io.deephaven.extensions.barrage.BarrageMessageWriterImpl.ByteArrayWriter

len, raw

Constructor Summary

Constructors

Constructor	Description
RowSetWriter(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()
protected void	ensureComputed()

Methods inherited from class io.deephaven.extensions.barrage.BarrageMessageWriterImpl.ByteArrayWriter

addToFlatBuffer

Methods inherited from class java.lang.Object

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

Constructor Details

RowSetWriter

public RowSetWriter(RowSet rowSet)
             throws IOException

Throws:

IOException

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable

ensureComputed

protected void ensureComputed()
                       throws IOException

Specified by:

ensureComputed in class BarrageMessageWriterImpl.ByteArrayWriter

Throws:

IOException

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