Hi, Currently, we want to use batch execution mode [0] and historical data to build state for our streaming application. Due to different between batch & streaming mode, we want to check current execution mode in custom operator. So our question is:
* Is there any API for custom operator to know current execution mode (batch or streaming)? * If we want to output after all elements of one specific key are processed, can we just use timer since timer is triggered at the end of input [0]? [0] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/execution_mode/ -- ChangZhuo Chen (陳昌倬) czchen@{czchen,debian}.org http://czchen.info/ Key fingerprint = BA04 346D C2E1 FE63 C790 8793 CC65 B0CD EC27 5D5B
signature.asc
Description: PGP signature
