Package io.deephaven.barrage.util

Class BarrageUtil

java.lang.Object

io.deephaven.barrage.util.BarrageUtil

public class BarrageUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BarrageUtil.ConvertedArrowSchema

Field Summary

Fields

Modifier and Type	Field	Description
static final BarrageSnapshotOptions	DEFAULT_SNAPSHOT_DESER_OPTIONS
static final long	FLATBUFFER_MAGIC
static final io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.ArrowType.FixedSizeBinary	LOCAL_DATE_TYPE
static final io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.ArrowType.FixedSizeBinary	LOCAL_TIME_TYPE
static final long	MAX_SNAPSHOT_CELL_COUNT
static final long	MIN_SNAPSHOT_CELL_COUNT
static final io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.ArrowType.Timestamp	NANO_SINCE_EPOCH_TYPE	Note that arrow's wire format states that Timestamps without timezones are not UTC -- that they are no timezone at all.
static final double	TARGET_SNAPSHOT_PERCENTAGE

Constructor Summary

Constructors

Constructor	Description
BarrageUtil()

Method Summary

Modifier and Type	Method	Description
static @NotNull Map<String,String>	attributesToMetadata(@NotNull Map<String,Object> attributes)
static Stream<io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.Field>	columnDefinitionsToFields(@NotNull Map<String,String> columnDescriptions, @Nullable MutableInputTable inputTable, @NotNull TableDefinition tableDefinition, @NotNull Collection<ColumnDefinition> columnDefinitions, @NotNull Function<String,Map<String,String>> fieldMetadataFactory, @NotNull Map<String,Object> attributes)
static Stream<io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.Field>	columnDefinitionsToFields(@NotNull Map<String,String> columnDescriptions, @Nullable MutableInputTable inputTable, @NotNull TableDefinition tableDefinition, @NotNull Collection<ColumnDefinition> columnDefinitions, @NotNull Function<String,Map<String,String>> fieldMetadataFactory, @NotNull Map<String,Object> attributes, boolean columnsAsList)
static BarrageUtil.ConvertedArrowSchema	convertArrowSchema(io.deephaven.proto.backplane.grpc.ExportedTableCreationResponse response)
static BarrageUtil.ConvertedArrowSchema	convertArrowSchema(io.deephaven.shadow.client.flight.org.apache.arrow.flatbuf.Schema schema)
static BarrageUtil.ConvertedArrowSchema	convertArrowSchema(io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.Schema schema)
static int	makeTableSchemaPayload(@NotNull io.deephaven.shadow.client.flight.com.google.flatbuffers.FlatBufferBuilder builder, @NotNull StreamReaderOptions options, @NotNull TableDefinition tableDefinition, @NotNull Map<String,Object> attributes)
static void	putMetadata(Map<String,String> metadata, String key, String value)
static io.deephaven.shadow.client.flight.com.google.protobuf.ByteString	schemaBytes(@NotNull ToIntFunction<io.deephaven.shadow.client.flight.com.google.flatbuffers.FlatBufferBuilder> schemaPayloadWriter)
static io.deephaven.shadow.client.flight.com.google.protobuf.ByteString	schemaBytesFromTable(@NotNull Table table)
static io.deephaven.shadow.client.flight.com.google.protobuf.ByteString	schemaBytesFromTableDefinition(@NotNull TableDefinition tableDefinition, @NotNull Map<String,Object> attributes)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_SNAPSHOT_DESER_OPTIONS

public static final BarrageSnapshotOptions DEFAULT_SNAPSHOT_DESER_OPTIONS

FLATBUFFER_MAGIC

public static final long FLATBUFFER_MAGIC

See Also:

• Constant Field Values

TARGET_SNAPSHOT_PERCENTAGE

public static final double TARGET_SNAPSHOT_PERCENTAGE

MIN_SNAPSHOT_CELL_COUNT

public static final long MIN_SNAPSHOT_CELL_COUNT

MAX_SNAPSHOT_CELL_COUNT

public static final long MAX_SNAPSHOT_CELL_COUNT

LOCAL_DATE_TYPE

public static final io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.ArrowType.FixedSizeBinary LOCAL_DATE_TYPE

LOCAL_TIME_TYPE

public static final io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.ArrowType.FixedSizeBinary LOCAL_TIME_TYPE

NANO_SINCE_EPOCH_TYPE

public static final io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.ArrowType.Timestamp NANO_SINCE_EPOCH_TYPE

Note that arrow's wire format states that Timestamps without timezones are not UTC -- that they are no timezone at all. It's very important that we mark these times as UTC.

Constructor Details

BarrageUtil

public BarrageUtil()

Method Details

schemaBytesFromTable

public static io.deephaven.shadow.client.flight.com.google.protobuf.ByteString schemaBytesFromTable(@NotNull
 @NotNull Table table)

schemaBytesFromTableDefinition

public static io.deephaven.shadow.client.flight.com.google.protobuf.ByteString schemaBytesFromTableDefinition(@NotNull
 @NotNull TableDefinition tableDefinition,
 @NotNull
 @NotNull Map<String,Object> attributes)

schemaBytes

public static io.deephaven.shadow.client.flight.com.google.protobuf.ByteString schemaBytes(@NotNull
 @NotNull ToIntFunction<io.deephaven.shadow.client.flight.com.google.flatbuffers.FlatBufferBuilder> schemaPayloadWriter)

makeTableSchemaPayload

public static int makeTableSchemaPayload(@NotNull
 @NotNull io.deephaven.shadow.client.flight.com.google.flatbuffers.FlatBufferBuilder builder,
 @NotNull
 @NotNull StreamReaderOptions options,
 @NotNull
 @NotNull TableDefinition tableDefinition,
 @NotNull
 @NotNull Map<String,Object> attributes)

attributesToMetadata

@NotNull
public static @NotNull Map<String,String> attributesToMetadata(@NotNull
 @NotNull Map<String,Object> attributes)

columnDefinitionsToFields

public static Stream<io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.Field> columnDefinitionsToFields(@NotNull
 @NotNull Map<String,String> columnDescriptions,
 @Nullable
 @Nullable MutableInputTable inputTable,
 @NotNull
 @NotNull TableDefinition tableDefinition,
 @NotNull
 @NotNull Collection<ColumnDefinition> columnDefinitions,
 @NotNull
 @NotNull Function<String,Map<String,String>> fieldMetadataFactory,
 @NotNull
 @NotNull Map<String,Object> attributes)

columnDefinitionsToFields

public static Stream<io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.Field> columnDefinitionsToFields(@NotNull
 @NotNull Map<String,String> columnDescriptions,
 @Nullable
 @Nullable MutableInputTable inputTable,
 @NotNull
 @NotNull TableDefinition tableDefinition,
 @NotNull
 @NotNull Collection<ColumnDefinition> columnDefinitions,
 @NotNull
 @NotNull Function<String,Map<String,String>> fieldMetadataFactory,
 @NotNull
 @NotNull Map<String,Object> attributes,
 boolean columnsAsList)

putMetadata

public static void putMetadata(Map<String,String> metadata,
 String key,
 String value)

convertArrowSchema

public static BarrageUtil.ConvertedArrowSchema convertArrowSchema(io.deephaven.proto.backplane.grpc.ExportedTableCreationResponse response)

convertArrowSchema

public static BarrageUtil.ConvertedArrowSchema convertArrowSchema(io.deephaven.shadow.client.flight.org.apache.arrow.flatbuf.Schema schema)

convertArrowSchema

public static BarrageUtil.ConvertedArrowSchema convertArrowSchema(io.deephaven.shadow.client.flight.org.apache.arrow.vector.types.pojo.Schema schema)