众所周知,flink有两个核心api(datastream/dataset),但是当我使用flink sql client提交作业时,我不需要选择流模式或批处理模式。那么flink sql client是如何决定使用批处理模式和流模式的呢。我在官方文件中没有找到答案。那么,我想知道FlinkSQL客户端如何区分批处理模式和流模式?
mutmk8jj1#
启动flink的sql客户机时,可以通过
sql-client.sh embedded -d <default environment file> -e <session environment file>
环境文件是描述目录和表执行环境的yaml文件,包括是使用批处理还是流式处理:
execution: type: streaming
有关更多详细信息,请参阅文档。
1条答案
按热度按时间mutmk8jj1#
启动flink的sql客户机时,可以通过
环境文件是描述目录和表执行环境的yaml文件,包括是使用批处理还是流式处理:
有关更多详细信息,请参阅文档。