Hi, Currently, we want to use batch execution mode [0] to consume historical data and rebuild states for our streaming application. The Flink app will be run on-demand and close after complete all the file processing. We implement a SourceFuntion [1] to consume bounded parquet files from GCS. However, the function will be detected as Batch Mode.
Our question is, how to implement a SourceFunction as a Bounded DataStream? Thanks! Oscar [0] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/execution_mode/ [1] https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/functions/source/SourceFunction.html
