流批选择
之前版本
1 | //流 |
现在版本
通过执行模式 execution mode选择
1 流处理 streaming 默认
2 批处理 batch
3 自动 automatic
(1) 通过命令行
1 | flink run -Dexecution.runtime-mode=BATCH/../.. |
(2)代码
1 | env.setRuntimeMode(RuntimeExecutionMode.STREAMING); |
之前版本
1 | //流 |
现在版本
通过执行模式 execution mode选择
1 流处理 streaming 默认
2 批处理 batch
3 自动 automatic
(1) 通过命令行
1 | flink run -Dexecution.runtime-mode=BATCH/../.. |
(2)代码
1 | env.setRuntimeMode(RuntimeExecutionMode.STREAMING); |