Package io.deephaven.extensions.barrage

Class BarrageMessageWriterImpl.SnapshotView

java.lang.Object

io.deephaven.extensions.barrage.BarrageMessageWriterImpl.SnapshotView

All Implemented Interfaces:

BarrageMessageWriter.MessageView, BarrageMessageWriterImpl.RecordBatchMessageView

Enclosing class:

BarrageMessageWriterImpl

protected class BarrageMessageWriterImpl.SnapshotView
extends Object
implements BarrageMessageWriterImpl.RecordBatchMessageView

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SnapshotView(BarrageSnapshotOptions options, @Nullable RowSet viewport, boolean reverseViewport, @Nullable RowSet keyspaceViewport, @Nullable BitSet subscribedColumns)

Method Summary

Modifier and Type	Method	Description
RowSet	addRowOffsets()
void	forEachStream(Consumer<DefensiveDrainable> visitor)
protected ByteBuffer	getSnapshotMetadata()
RowSet	modRowOffsets(int col)
BarrageOptions	options()

Methods inherited from class java.lang.Object

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

Constructor Details

SnapshotView

protected SnapshotView(BarrageSnapshotOptions options,
 @Nullable
 @Nullable RowSet viewport,
 boolean reverseViewport,
 @Nullable
 @Nullable RowSet keyspaceViewport,
 @Nullable
 @Nullable BitSet subscribedColumns)

Method Details

forEachStream

public void forEachStream(Consumer<DefensiveDrainable> visitor)
                   throws IOException

Specified by:

forEachStream in interface BarrageMessageWriter.MessageView

Throws:

IOException

options

public BarrageOptions options()

Specified by:

options in interface BarrageMessageWriterImpl.RecordBatchMessageView

addRowOffsets

public RowSet addRowOffsets()

Specified by:

addRowOffsets in interface BarrageMessageWriterImpl.RecordBatchMessageView

modRowOffsets

public RowSet modRowOffsets(int col)

Specified by:

modRowOffsets in interface BarrageMessageWriterImpl.RecordBatchMessageView

getSnapshotMetadata

protected ByteBuffer getSnapshotMetadata()
                                  throws IOException

Throws:

IOException