ShufflePartitioner (Flink : Streaming Java 1.18.1-cp5 API)

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

Type Parameters:

T - Type of the Tuple

All Implemented Interfaces:

Serializable, org.apache.flink.runtime.io.network.api.writer.ChannelSelector<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<T>>>
```
@Internal
public class ShufflePartitioner<T>
extends StreamPartitioner<T>
```
Partitioner that distributes the data equally by selecting one output channel randomly.

See Also:

Serialized Form

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

Constructor Summary

Constructors
Constructor Description

ShufflePartitioner()

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)`
`String`	`toString()`

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

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

- Constructor Detail
  - ShufflePartitioner
```
public ShufflePartitioner()
```
- Method Detail
  - 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