Package io.deephaven.extensions.barrage

Class BarrageMessageWriterImpl.SubView

java.lang.Object

io.deephaven.extensions.barrage.BarrageMessageWriterImpl.SubView

All Implemented Interfaces:

BarrageMessageWriter.MessageView, BarrageMessageWriterImpl.RecordBatchMessageView

Enclosing class:

BarrageMessageWriterImpl

protected class BarrageMessageWriterImpl.SubView
extends Object
implements BarrageMessageWriterImpl.RecordBatchMessageView

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SubView(BarrageSubscriptionOptions options, boolean isInitialSnapshot, boolean isFullSubscription, @Nullable RowSet viewport, boolean reverseViewport, @Nullable RowSet keyspaceViewportPrev, @Nullable RowSet keyspaceViewport, @Nullable BitSet subscribedColumns)

Method Summary

Modifier and Type	Method	Description
RowSet	addRowOffsets()
void	forEachStream(Consumer<DefensiveDrainable> visitor)
protected ByteBuffer	getSubscriptionMetadata()	Generate the metadata for this subscription.
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

SubView

protected SubView(BarrageSubscriptionOptions options,
 boolean isInitialSnapshot,
 boolean isFullSubscription,
 @Nullable
 @Nullable RowSet viewport,
 boolean reverseViewport,
 @Nullable
 @Nullable RowSet keyspaceViewportPrev,
 @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

getSubscriptionMetadata

protected ByteBuffer getSubscriptionMetadata()
                                      throws IOException

Generate the metadata for this subscription. For a standard subscription, this is a flatbuffer representing a BarrageMessageWrapper containing a payload of BarrageUpdateMetadata.

Returns:

a ByteBuffer representing the metadata for this subscription

Throws:

IOException - if the metadata could not be serialized