ForwardPartitioner (Flink : Streaming Java 1.19.3-cp1 API)

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

Type Parameters:

T - Type of the elements in the Stream

All Implemented Interfaces:

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

Direct Known Subclasses:

ForwardForConsecutiveHashPartitioner, ForwardForUnspecifiedPartitioner
```
@Internal
public class ForwardPartitioner<T>
extends StreamPartitioner<T>
```
Partitioner that forwards elements only to the locally running downstream operation.

See Also:

Serialized Form

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

Constructor Summary

Constructors
Constructor Description

ForwardPartitioner()

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.
`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.
`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
disableUnalignedCheckpoints, equals, hashCode, isBroadcast, isSupportsUnalignedCheckpoint, setup

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

- Constructor Detail
  - ForwardPartitioner
```
public ForwardPartitioner()
```
- Method Detail
  - selectChannel
```
public int selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<StreamRecord<T>> record)
```
  - 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
  - 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>
  - getUpstreamSubtaskStateMapper
```
public org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper getUpstreamSubtaskStateMapper()
```
    Description copied from class: StreamPartitioner
    
    Defines the behavior of this partitioner, when upstream rescaled during recovery of in-flight data.
    
    Overrides:
    
    getUpstreamSubtaskStateMapper in class StreamPartitioner<T>