public < K extends Comparable < K > > PartitionOperator < T > partitionByHash ( KeySelector < T , K > keyExtractor ) { final TypeInformation < K > keyType = TypeExtractor . getKeySelectorTypes ( keyExtractor , getType ( ) ) ; return new PartitionOperator <> ( this , PartitionMethod . HASH , new Keys . SelectorFunctionKeys <> ( clean ( keyExtractor ) , this . getType ( ) , keyType ) , Utils . getCallLocationName ( ) ) ; }
Partitions a DataSet using the specified KeySelector .