Package io.deephaven.extensions.barrage
Class BarrageSnapshotOptions
java.lang.Object
io.deephaven.extensions.barrage.BarrageSnapshotOptions
- All Implemented Interfaces:
StreamReaderOptions
@Immutable
public abstract class BarrageSnapshotOptions
extends Object
implements StreamReaderOptions
-
Nested Class Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionint
appendTo
(com.google.flatbuffers.FlatBufferBuilder builder) int
builder()
int
static BarrageSnapshotOptions
of
(io.deephaven.barrage.flatbuf.BarrageSnapshotOptions options) static BarrageSnapshotOptions
of
(io.deephaven.barrage.flatbuf.BarrageSnapshotRequest snapshotRequest) boolean
By default, prefer to communicate null values using the arrow-compatible validity structure.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.deephaven.extensions.barrage.util.StreamReaderOptions
columnsAsList
-
Constructor Details
-
BarrageSnapshotOptions
public BarrageSnapshotOptions()
-
-
Method Details
-
builder
-
of
public static BarrageSnapshotOptions of(io.deephaven.barrage.flatbuf.BarrageSnapshotOptions options) -
of
public static BarrageSnapshotOptions of(io.deephaven.barrage.flatbuf.BarrageSnapshotRequest snapshotRequest) -
useDeephavenNulls
@Default public boolean useDeephavenNulls()By default, prefer to communicate null values using the arrow-compatible validity structure.- Specified by:
useDeephavenNulls
in interfaceStreamReaderOptions
- Returns:
- whether to use deephaven nulls
-
batchSize
@Default public int batchSize()- Specified by:
batchSize
in interfaceStreamReaderOptions
- Returns:
- the preferred batch size if specified
-
maxMessageSize
@Default public int maxMessageSize()- Specified by:
maxMessageSize
in interfaceStreamReaderOptions
- Returns:
- the maximum GRPC message size if specified
-
columnConversionMode
- Specified by:
columnConversionMode
in interfaceStreamReaderOptions
- Returns:
- the conversion mode to use for object columns
-
appendTo
public int appendTo(com.google.flatbuffers.FlatBufferBuilder builder)
-