RebalancePartitioner (Flink : Streaming Java 1.18.1-cp7 API)

java.lang.Object
- org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T>
- - org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner<T>

Type Parameters:

T - Type of the elements in the Stream being rebalanced

All Implemented Interfaces:

Serializable, org.apache.flink.runtime.io.network.api.writer.ChannelSelector<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<T>>>
```
@Internal
public class RebalancePartitioner<T>
extends StreamPartitioner<T>
```
Partitioner that distributes the data equally by cycling through the output channels.

See Also:

Serialized Form

Field Summary
- Fields inherited from class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner
  numberOfChannels

Constructor Summary

Constructors
Constructor Description

RebalancePartitioner()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`StreamPartitioner<T>`	`copy()`
`org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper`	`getDownstreamSubtaskStateMapper()`	Defines the behavior of this partitioner, when downstream rescaled during recovery of in-flight data.
`boolean`	`isPointwise()`
`int`	`selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<T>> record)`
`void`	`setup(int numberOfChannels)`
`String`	`toString()`

Methods inherited from class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner
equals, getUpstreamSubtaskStateMapper, hashCode, isBroadcast

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - RebalancePartitioner
```
public RebalancePartitioner()
```
- Method Detail
  - setup
```
public void setup(int numberOfChannels)
```
    Specified by:
    
    setup in interface org.apache.flink.runtime.io.network.api.writer.ChannelSelector<T>
    
    Overrides:
    
    setup in class StreamPartitioner<T>
  - selectChannel
```
public int selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<T>> record)
```
  - getDownstreamSubtaskStateMapper
```
public org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper getDownstreamSubtaskStateMapper()
```
    Description copied from class: StreamPartitioner
    
    Defines the behavior of this partitioner, when downstream rescaled during recovery of in-flight data.
    
    Specified by:
    
    getDownstreamSubtaskStateMapper in class StreamPartitioner<T>
  - copy
```
public StreamPartitioner<T> copy()
```
    Specified by:
    
    copy in class StreamPartitioner<T>
  - isPointwise
```
public boolean isPointwise()
```
    Specified by:
    
    isPointwise in class StreamPartitioner<T>
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object