Package io.deephaven.extensions.barrage

Class BarrageStreamGeneratorImpl.SnapshotView

java.lang.Object

io.deephaven.extensions.barrage.BarrageStreamGeneratorImpl.SnapshotView

All Implemented Interfaces:

BarrageStreamGeneratorImpl.View

Enclosing class:

BarrageStreamGeneratorImpl

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

Field Summary

Fields

Modifier and Type	Field	Description
final RowSet	addRowKeys
final RowSet	addRowOffsets
final BarrageStreamGeneratorImpl	generator
final RowSet	keyspaceViewport
final long	numAddRows
final BarrageSnapshotOptions	options
final boolean	reverseViewport
final BitSet	subscribedColumns
final RowSet	viewport

Constructor Summary

Constructors

Constructor	Description
SnapshotView(BarrageStreamGeneratorImpl generator, BarrageSnapshotOptions options, @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)
final 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 BarrageSnapshotOptions options

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

addRowKeys

public final RowSet addRowKeys

addRowOffsets

public final RowSet addRowOffsets

Constructor Details

SnapshotView

public SnapshotView(BarrageStreamGeneratorImpl generator,
 BarrageSnapshotOptions options,
 @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 final 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