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

Field Summary

Fields

Modifier and Type	Field and Description
protected int	numberOfChannels

Constructor Summary

Constructors

Constructor and Description
StreamPartitioner()

Method Summary

Modifier and Type	Method and Description
abstract StreamPartitioner<T>	copy()
boolean	isBroadcast() Returns whether the channel selector always selects all the output channels.
void	setup(int numberOfChannels) Initializes the channel selector with the number of output channels.

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

selectChannel

Field Detail

numberOfChannels

protected int numberOfChannels

Constructor Detail

StreamPartitioner

public StreamPartitioner()

Method Detail

setup

public void setup(int numberOfChannels)

Description copied from interface: ChannelSelector

Initializes the channel selector with the number of output channels.

Specified by:

setup in interface ChannelSelector<SerializationDelegate<StreamRecord<T>>>

Parameters:

numberOfChannels - the total number of output channels which are attached to respective output gate.

isBroadcast

public boolean isBroadcast()

Description copied from interface: ChannelSelector

Returns whether the channel selector always selects all the output channels.

Specified by:

isBroadcast in interface ChannelSelector<SerializationDelegate<StreamRecord<T>>>

Returns:

true if the selector is for broadcast mode.

copy

public abstract StreamPartitioner<T> copy()