package parallel
Ordering
- Alphabetic
Visibility
- Public
- Protected
Value Members
- object AsyncSupport
- 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
.
- object BatchingParallelIngestionPipe
- object InitializeParallelIngestion extends Serializable
- object ParallelIndexerFactory
- object ParallelIndexerSubscription extends Serializable