Value Members

1.  object AsyncSupport
2.  object BatchN

   Forms dynamically-sized batches based on downstream backpressure.

   Forms dynamically-sized batches based on downstream backpressure.

   • Under light load, this flow emits batches of size 1.
   • Under moderate load, this flow emits batches of even sizes.
   • Under heavy load (dowstream saturated), this flow emits batches of maxBatchSize.
3.  object BatchingParallelIngestionPipe
4.  object InitializeParallelIngestion extends Serializable
5.  object ParallelIndexerFactory
6.  object ParallelIndexerSubscription extends Serializable