org.apache.flink.streaming.api.functions.python

Class PartitionCustomKeySelector

java.lang.Object

org.apache.flink.streaming.api.functions.python.PartitionCustomKeySelector

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.java.functions.KeySelector<org.apache.flink.types.Row,Integer>

@Internal
public class PartitionCustomKeySelector
extends Object
implements org.apache.flink.api.java.functions.KeySelector<org.apache.flink.types.Row,Integer>

The PartitionCustomKeySelector will return the first field of the input row value. The value of the first field is the desired partition index which is computed according to user defined partitioner and keySelector function.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PartitionCustomKeySelector()

Method Summary

Modifier and Type	Method and Description
Integer	getKey(org.apache.flink.types.Row value)

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionCustomKeySelector

public PartitionCustomKeySelector()

Method Detail

getKey

public Integer getKey(org.apache.flink.types.Row value)
               throws Exception

Specified by:

getKey in interface org.apache.flink.api.java.functions.KeySelector<org.apache.flink.types.Row,Integer>

Throws:

Exception