3、Flink 与 DataStream API 集成之批运行模式详解_flink datastream 攒批

a）概述

批处理运行时模式是有界 Flink 程序的专用执行模式；有界性是数据源的一个属性，它告诉我们来自该源的所有记录在执行之前是否已知，或者新数据是否会显示，可能是无限期的；反过来，如果作业的所有源都有界，则作业是有界的，否则是无界的；

表 API 和 SQL 计划器为这两种模式中的任何一种提供了一组专门的优化器规则和运行时运算符；运行时模式不是从源自动派生的，在实例化 StreamTableEnvironment 时，必须显式设置；

import org.apache.flink.api.common.RuntimeExecutionMode;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.api.EnvironmentSettings;

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setRuntimeMode(RuntimeExecutionMode.BATCH);
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

// or

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tableEnv = StreamTableEnvir
1
2
3
4
5
6
7
8
9
10
11
12