Flink SQL Client 如何区分批处理模式和流处理模式?
How does the Flink SQL Client distinguish batch mode and stream mode?
众所周知,Flink有两个核心API(DataStream/DataSet),但是当我使用flinkSqlClient提交作业时,不需要选择流还是批mode.So Flink如何SQL Client决定使用batch模式和stream模式。我没有在官方文档中找到答案。
那么,我想知道Flink SQL Client如何区分batch mode和stream mode?
启动 Flink 的 SQL 客户端时,您可以通过
指定要使用的环境
sql-client.sh embedded -d <default environment file> -e <session environment file>
环境文件是描述目录和table执行环境的YAML文件,包括是使用批处理还是流处理:
execution:
type: streaming
有关详细信息,请参阅 the documentation。
众所周知,Flink有两个核心API(DataStream/DataSet),但是当我使用flinkSqlClient提交作业时,不需要选择流还是批mode.So Flink如何SQL Client决定使用batch模式和stream模式。我没有在官方文档中找到答案。 那么,我想知道Flink SQL Client如何区分batch mode和stream mode?
启动 Flink 的 SQL 客户端时,您可以通过
指定要使用的环境sql-client.sh embedded -d <default environment file> -e <session environment file>
环境文件是描述目录和table执行环境的YAML文件,包括是使用批处理还是流处理:
execution:
type: streaming
有关详细信息,请参阅 the documentation。