Searched defs:batch_sink (Results 1 – 3 of 3) sorted by relevance
35 let batch_sink = BatchSink::new( in batching() localVariable80 let batch_sink = PartitionBatchSink::new( in partitioned_batching() localVariable
122 pub fn batch_sink<B, L, S, Request>( in batch_sink() method