THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
A few APIs to support local aggregation need to be added to DataStream class, list below:
Code Block | ||
---|---|---|
| ||
KeyedStream<TLocalKeyedStream<T, Tuple> localKeyBy(int… fields); KeyedStream<TLocalKeyedStream<T, Tuple> localKeyBy(Keys<T> keys); <K> KeyedStream<TLocalKeyedStream<T, K> localKeyBy(KeySelector<T, K> keySelector); <K> KeyedStream<TLocalKeyedStream<T, K> localKeyBy(KeySelector<T, K> keySelector, TypeInformation<K> keyType); |
...