Package io.deephaven.extensions.barrage.util
package io.deephaven.extensions.barrage.util
-
ClassDescriptionThis class allows the incremental making of a BarrageTable from Arrow IPC messages, starting with an Arrow Schema message followed by zero or more RecordBatchesThis exception is thrown when Barrage encounters unexpected state while marshalling a gRPC message.A gRPC streaming reader that keeps stream specific context and converts
InputStreams toBarrageMessages.A defensiveDrainableimplementation that supports the non-read methods ofInputStream.Lifted from Apache Arrow project: https://github.com/apache/arrow/blob/ee62d970338f173fff4c0d11b975fe30b5fda70b/java/memory/memory-core/src/main/java/org/apache/arrow/memory/util/Float16.java Changes made: Keep Only the Method Used Use floatToIntBits over floatToIntRawBits for GWT compilation The class is a utility class to manipulate half-precision 16-bit IEEE 754 floating point data types (also called fp16 or binary16).Utilities for creating schemas fromHierarchicalTableinstances.TableKeyimplementation for TableService.TableLocationKeyimplementation for TableService.This class produces Arrow Ipc Messages for a Deephaven table, including the schema and all columnar data.