DEFAULT_CONCURRENCY

val DEFAULT_CONCURRENCY: Int

Default concurrency limit that is used by flattenMerge and flatMapMerge operators. It is 16 by default and can be changed on JVM using DEFAULT_CONCURRENCY_PROPERTY_NAME property.

Sources

common source
Link copied to clipboard