public interface ConfigurableStreamPartitioner
StreamPartitioner
which have to be configured with the maximum parallelism
of the stream transformation. The configure method is called by the StreamGraph when adding
internal edges.
This interface is required since the stream partitioners are instantiated eagerly. Due to that the maximum parallelism might not have been determined and needs to be set at a stage when the maximum parallelism could have been determined.
Modifier and Type | Method and Description |
---|---|
void |
configure(int maxParallelism)
Configure the
StreamPartitioner with the maximum parallelism of the down stream
operator. |
void configure(int maxParallelism)
StreamPartitioner
with the maximum parallelism of the down stream
operator.maxParallelism
- Maximum parallelism of the down stream operator.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.