Class StreamPartitioner<T>
- 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 specialChannelSelectorfor use in streaming programs.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description protected intnumberOfChannels
-
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()booleanequals(Object o)abstract org.apache.flink.runtime.io.network.api.writer.SubtaskStateMappergetDownstreamSubtaskStateMapper()Defines the behavior of this partitioner, when downstream rescaled during recovery of in-flight data.org.apache.flink.runtime.io.network.api.writer.SubtaskStateMappergetUpstreamSubtaskStateMapper()Defines the behavior of this partitioner, when upstream rescaled during recovery of in-flight data.inthashCode()booleanisBroadcast()abstract booleanisPointwise()voidsetup(int numberOfChannels)
-
-
-
Method Detail
-
setup
public void setup(int numberOfChannels)
- Specified by:
setupin interfaceorg.apache.flink.runtime.io.network.api.writer.ChannelSelector<T>
-
isBroadcast
public boolean isBroadcast()
- Specified by:
isBroadcastin interfaceorg.apache.flink.runtime.io.network.api.writer.ChannelSelector<T>
-
copy
public abstract StreamPartitioner<T> copy()
-
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()
-
-