THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * Reinterprets the given {@link DataStream} as a {@link KeyedStream}, which extracts keys with * the given {@link KeySelector}. The precondition is that the base stream is already grouped by * key and partitioned. * * <p>With the reinterpretation, the upstream operators can now be chained with the downstream * operator and therefore * avoiding shuffling data and network consumption between two subtasks. * If shuffling or network consumption is acceptable, * {@link DataStream#keyBy(KeySelector)} is * recommended. * * <p>"Pre-KeyedStream": The base stream is streaming from the external system, where it has * been grouped by key and partitioned. * * <p>IMPORTANT: For a "Pre-KeyedStream", the maximum number of currently existing splits must * not be larger than the maximum * number of key-groups. Since every split would be mapped to one * key-group. To config the number of key-group, please config the * maximum supported parallelism. * * <p>IMPORTANT: For a "Pre-KeyedStream", if chaining is disabled for debugging, this method * might not work. * * @param keySelector Function that defines how keys are extracted from the data stream. * @param <K> Type of the extracted keys. * @return The reinterpretation of the {@link DataStream} as a {@link KeyedStream}. */ public <K> KeyedStream<T, K> reinterpretAsKeyedStream(KeySelector<T, K> keySelector) {} /** * @see #reinterpretAsKeyedStream(KeySelector) * * @param keySelector Function that defines how keys are extracted from the data stream. * @param <K> Type of the extracted keys. * @return The reinterpretation of the {@link DataStream} as a {@link KeyedStream}. */ public <K> KeyedStream<T, K> reinterpretAsKeyedStream(KeySelector<T, K> keySelector, TypeInformation<K> typeInfo) {} |
...