org.apache.flink.streaming.runtime.partitioner

Class StreamPartitioner<T>

java.lang.Object

org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T>

All Implemented Interfaces:

Serializable, ChannelSelector<SerializationDelegate<StreamRecord<T>>>

Direct Known Subclasses:

BroadcastPartitioner, CustomPartitionerWrapper, ForwardPartitioner, GlobalPartitioner, KeyGroupStreamPartitioner, RebalancePartitioner, RescalePartitioner, ShufflePartitioner

@Internal
public abstract class StreamPartitioner<T>
extends Object
implements ChannelSelector<SerializationDelegate<StreamRecord<T>>>, Serializable

A special ChannelSelector for use in streaming programs.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StreamPartitioner()

Method Summary

Modifier and Type	Method and Description
abstract StreamPartitioner<T>	copy()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

selectChannels

Constructor Detail

StreamPartitioner

public StreamPartitioner()

Method Detail

copy

public abstract StreamPartitioner<T> copy()