Skip to main content

Module stream

Module stream 

Source

Structsยง

BatchAccumulator ๐Ÿ”’
Coalesces consecutive ready record batches into one outgoing group.
CoalescingBatcher ๐Ÿ”’
Forwards ready record batches on the non-verbose path, coalescing consecutive small batches into one outgoing group before sending.
FlightRecordBatchStream
StreamMetrics ๐Ÿ”’
Metrics collector for Flight stream with RAII logging pattern

Enumsยง

FlightRecordBatchSource
FlightRecordBatchStreamInput
Determines whether a Flight result is ready now or initialized asynchronously.