Skip to main content

Module stream

servers::grpc::flight

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.