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
ConstructorsModifierConstructorDescriptionprotectedSnapshotView(BarrageSnapshotOptions options, @Nullable RowSet viewport, boolean reverseViewport, @Nullable RowSet keyspaceViewport, @Nullable BitSet subscribedColumns) -
Method Summary
Modifier and TypeMethodDescriptionvoidforEachStream(Consumer<DefensiveDrainable> visitor) protected ByteBuffermodRowOffsets(int col) options()
-
Constructor Details
-
SnapshotView
protected SnapshotView(BarrageSnapshotOptions options, @Nullable @Nullable RowSet viewport, boolean reverseViewport, @Nullable @Nullable RowSet keyspaceViewport, @Nullable @Nullable BitSet subscribedColumns)
-
-
Method Details
-
forEachStream
- Specified by:
forEachStreamin interfaceBarrageMessageWriter.MessageView- Throws:
IOException
-
options
- Specified by:
optionsin interfaceBarrageMessageWriterImpl.RecordBatchMessageView
-
addRowOffsets
- Specified by:
addRowOffsetsin interfaceBarrageMessageWriterImpl.RecordBatchMessageView
-
modRowOffsets
- Specified by:
modRowOffsetsin interfaceBarrageMessageWriterImpl.RecordBatchMessageView
-
getSnapshotMetadata
- Throws:
IOException
-