StreamPartitioner (Flink : Streaming Java 1.18.1-cp1 API)

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

All Implemented Interfaces:

Serializable, org.apache.flink.runtime.io.network.api.writer.ChannelSelector<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<T>>>

Direct Known Subclasses:

BroadcastPartitioner, CustomPartitionerWrapper, ForwardPartitioner, GlobalPartitioner, KeyGroupStreamPartitioner, RebalancePartitioner, RescalePartitioner, ShufflePartitioner
```
@Internal
public abstract class StreamPartitioner<T>
extends Object
implements org.apache.flink.runtime.io.network.api.writer.ChannelSelector<org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<T>>>, Serializable
```
A special ChannelSelector for use in streaming programs.

See Also:

Serialized Form

Field Summary

Fields
Modifier and Type Field Description

protected int numberOfChannels

Constructor Summary

Constructors
Constructor Description

StreamPartitioner()

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`abstract StreamPartitioner<T>`	`copy()`
`boolean`	`equals(Object o)`
`abstract 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.
`org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper`	`getUpstreamSubtaskStateMapper()`	Defines the behavior of this partitioner, when upstream rescaled during recovery of in-flight data.
`int`	`hashCode()`
`boolean`	`isBroadcast()`
`abstract boolean`	`isPointwise()`
`void`	`setup(int numberOfChannels)`

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

Methods inherited from interface org.apache.flink.runtime.io.network.api.writer.ChannelSelector
selectChannel

- Field Detail
  - numberOfChannels
```
protected int numberOfChannels
```
- Constructor Detail
  - StreamPartitioner
```
public StreamPartitioner()
```
- Method Detail
  - setup
```
public void setup(int numberOfChannels)
```
    Specified by:
    
    setup in interface org.apache.flink.runtime.io.network.api.writer.ChannelSelector<T>
  - isBroadcast
```
public boolean isBroadcast()
```
    Specified by:
    
    isBroadcast in interface org.apache.flink.runtime.io.network.api.writer.ChannelSelector<T>
  - copy
```
public abstract StreamPartitioner<T> copy()
```
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - getUpstreamSubtaskStateMapper
```
public org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper getUpstreamSubtaskStateMapper()
```
    Defines the behavior of this partitioner, when upstream rescaled during recovery of in-flight data.
  - getDownstreamSubtaskStateMapper
```
public abstract 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.
  - isPointwise
```
public abstract boolean isPointwise()
```