Package io.deephaven.extensions.barrage
package io.deephaven.extensions.barrage
-
ClassDescriptionA
BarrageMessageWritertakes aBarrageMessageand re-uses portions of the serialized payload across different subscribers that may subscribe to different viewports and columns.Represents a single update, which might be sent as multiple distinct payloads as necessary based in the implementation.Optional metrics API to track how many bytes a barrage message consumed, and how many nanoseconds it took to write it.This factory writes data in Arrow's IPC format which has a terse header and no room for metadata.Enable barrage performance metrics by setting theBarragePerformanceLog.enableAllconfiguration property, or by adding thetable keyas anAttributeMap.withAttributes(Map)attribute} to the table.Receives barrage snapshot performance statistics so that an integrator may record them, for example into binary logs.ThestatTypevalues recorded by barrage itself.Receives barrage subscription performance statistics so that an integrator may record them, for example into binary logs.Provides the factory for barrage performance sinks, allowing an integrator to record barrage performance data in addition to the in-memory tables exposed byBarragePerformanceLog.Supplies the sinks thatBarragePerformanceLogforwards its entries to.BarrageTypeInfo<FIELD_TYPE>Describes type info used by factory implementations when creating a ChunkReader.Arrow encoding to apply to a column when generating a Barrage schema.Width of the dictionary index (the values shipped in the RecordBatch).Width of the REErun_endsindex child.