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 defensive
Drainableimplementation that supports the non-read methods ofInputStream.Utilities for creating schemas fromHierarchicalTableinstances.TableKeyimplementation for TableService.TableLocationKeyimplementation for TableService.Thread safe re-usable reader that converts an InputStreams to BarrageMessages.This class produces Arrow Ipc Messages for a Deephaven table, including the schema and all columnar data.