Jan Lukavský
Jan Lukavský
…-INF/services Following this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https://issues.apache.org/jira/browse/MSHADE) filed for the change (usually before you...
After removing explicit partitioning, we have currently no explicit control over the parallelism of executing operators. This affects both batch and stream. There must be a way to give a...
Currently, when exception occurs during execution of LocalExecutor pipeline, the exception might get just logged and the executor remains hung. The exception should instead be grabbed and returned to the...
* add option to access element's timestamp from `Context` via `Context#getTimestamp()` * extend `Context` to `KeyedContext` with `KeyedContext#getKey` and pass it to keyed operators (RSBK, RBK, join)
Batch processing is not supposed to use time triggering, because the watermark should have only two values - `Long.MIN_VALUE` while processing any data and `Long.MAX_VALUE` after completion of the calculation....
In contrast to purely batch join, in stream processing the variety of join types is much broader. The main differences are: * streams have time ordering (as opposed to batch,...
Besides triggering on time (with `onTimer`) and the presence of an element (`onElement`), it would be good to allow users to construct triggers based on the data of the elements...
Introduce alternative "rich" UDFs to operators. These functions will have access to (at least) the following: ```java public interface RichUnaryFunction extends UnaryFunction { /** Called before the first element. */...
Support Flink 1.17. Closes #29939. ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Mention the appropriate issue...
### What would you like to happen? Analogous to `Comparator.comparing()`. ### Issue Priority Priority: 3 (nice-to-have improvement) ### Issue Components - [ ] Component: Python SDK - [X] Component: Java...