[FLINK-1060] Added methods to DataSet to explicitly hash-partition or rebalance the input of Map-based operators.