org.apache.flink.streaming.runtime.partitioner

Class CustomPartitionerWrapper<K,T>

java.lang.Object

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

org.apache.flink.streaming.runtime.partitioner.CustomPartitionerWrapper<K,T>

Type Parameters:

K - Type of the key

T - Type of the data

All Implemented Interfaces:

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

@Internal
public class CustomPartitionerWrapper<K,T>
extends StreamPartitioner<T>

Partitioner that selects the channel with a user defined partitioner function on a key.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner

numberOfChannels

Constructor Summary

Constructors

Constructor and Description
CustomPartitionerWrapper(Partitioner<K> partitioner, KeySelector<T,K> keySelector)

Method Summary

Modifier and Type	Method and Description
StreamPartitioner<T>	copy()
boolean	equals(Object o)
SubtaskStateMapper	getDownstreamSubtaskStateMapper() Defines the behavior of this partitioner, when downstream rescaled during recovery of in-flight data.
int	hashCode()
boolean	isPointwise()
int	selectChannel(SerializationDelegate<StreamRecord<T>> record) Returns the logical channel index, to which the given record should be written.
String	toString()

Methods inherited from class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner

getUpstreamSubtaskStateMapper, isBroadcast, setup

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

CustomPartitionerWrapper

public CustomPartitionerWrapper(Partitioner<K> partitioner,
                                KeySelector<T,K> keySelector)

Method Detail

selectChannel

public int selectChannel(SerializationDelegate<StreamRecord<T>> record)

Description copied from interface: ChannelSelector

Returns the logical channel index, to which the given record should be written. It is illegal to call this method for broadcast channel selectors and this method can remain not implemented in that case (for example by throwing UnsupportedOperationException).

Parameters:

record - the record to determine the output channels for.

Returns:

an integer number which indicates the index of the output channel through which the record shall be forwarded.

getDownstreamSubtaskStateMapper

public 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>

copy

public StreamPartitioner<T> copy()

Specified by:

copy in class StreamPartitioner<T>

equals

public boolean equals(Object o)

Overrides:

equals in class StreamPartitioner<T>

hashCode

public int hashCode()

Overrides:

hashCode in class StreamPartitioner<T>

isPointwise

public boolean isPointwise()

Specified by:

isPointwise in class StreamPartitioner<T>

toString

public String toString()

Overrides:

toString in class Object