Sorry, there are some typos that may be misleading. The SourceFunction will be detected as* Streaming Mode.*
陳樺威 <oscar8492...@gmail.com> 於 2021年6月3日 週四 下午1:29寫道： > 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 > > > >
