Package io.deephaven.extensions.barrage

Class BarrageStreamGeneratorImpl.SubView

java.lang.Object

io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.SubView

All Implemented Interfaces:

BarrageStreamGeneratorImpl.View

Enclosing class:

BarrageStreamGeneratorImpl

public static class BarrageStreamGeneratorImpl.SubView
extends Object
implements BarrageStreamGeneratorImpl.View

Field Summary

Fields

Modifier and Type	Field	Description
final RowSet	addRowKeys
final RowSet	addRowOffsets
final BarrageStreamGeneratorImpl	generator
final boolean	isInitialSnapshot
final RowSet	keyspaceViewport
final RowSet[]	modRowOffsets
final long	numAddRows
final long	numModRows
final BarrageSubscriptionOptions	options
final boolean	reverseViewport
final BitSet	subscribedColumns
final RowSet	viewport

Constructor Summary

Constructors

Constructor	Description
SubView(BarrageStreamGeneratorImpl generator, BarrageSubscriptionOptions options, boolean isInitialSnapshot, @Nullable RowSet viewport, boolean reverseViewport, @Nullable RowSet keyspaceViewport, @Nullable BitSet subscribedColumns)

Method Summary

Modifier and Type	Method	Description
RowSet	addRowOffsets()
int	clientMaxMessageSize()
void	forEachStream(Consumer<InputStream> visitor)
boolean	isViewport()
RowSet	modRowOffsets(int col)
StreamReaderOptions	options()

Methods inherited from class java.lang.Object

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

Field Details

generator

public final BarrageStreamGeneratorImpl generator

options

public final BarrageSubscriptionOptions options

isInitialSnapshot

public final boolean isInitialSnapshot

viewport

public final RowSet viewport

reverseViewport

public final boolean reverseViewport

keyspaceViewport

public final RowSet keyspaceViewport

subscribedColumns

public final BitSet subscribedColumns

numAddRows

public final long numAddRows

numModRows

public final long numModRows

addRowOffsets

public final RowSet addRowOffsets

addRowKeys

public final RowSet addRowKeys

modRowOffsets

public final RowSet[] modRowOffsets

Constructor Details

SubView

public SubView(BarrageStreamGeneratorImpl generator,
 BarrageSubscriptionOptions options,
 boolean isInitialSnapshot,
 @Nullable
 @Nullable RowSet viewport,
 boolean reverseViewport,
 @Nullable
 @Nullable RowSet keyspaceViewport,
 @Nullable
 @Nullable BitSet subscribedColumns)

Method Details

forEachStream

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

Specified by:

forEachStream in interface BarrageStreamGeneratorImpl.View

Throws:

IOException

clientMaxMessageSize

public int clientMaxMessageSize()

Specified by:

clientMaxMessageSize in interface BarrageStreamGeneratorImpl.View

isViewport

public boolean isViewport()

Specified by:

isViewport in interface BarrageStreamGeneratorImpl.View

options

public StreamReaderOptions options()

Specified by:

options in interface BarrageStreamGeneratorImpl.View

addRowOffsets

public RowSet addRowOffsets()

Specified by:

addRowOffsets in interface BarrageStreamGeneratorImpl.View

modRowOffsets

public RowSet modRowOffsets(int col)

Specified by:

modRowOffsets in interface BarrageStreamGeneratorImpl.View