PartitionCustomKeySelector (Flink : Python 2.1.1-cp1 API)

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 Description
  
  PartitionCustomKeySelector()
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method 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