OptionalbatchTimeout in milliseconds to flush incomplete batches.
When specified, incomplete batches will be flushed and processed after this timeout, even if they haven't reached the target batchSize. Useful for handling slow or irregular input streams.
OptionalbatchMaximum number of items per batch.
OptionalconcurrencyMaximum number of concurrent tasks.
map(): Controls how many individual items are processed concurrentlymapBatch(): Controls how many batches are processed concurrentlyOptionalpreserveWhether to preserve the order of results.
When true, results are yielded in the same order as the input items,
which may reduce throughput as processing waits for earlier items to complete.
When false, results are yielded as soon as they're available.
Configuration options for Stream.mapBatch operations.