RuntimeExecutionMode

STREAMING(默认)：适合有界数据和无界数据

BATCH：适合有界数据

AUTOMATIC：自动识别

BATCH执行模式用于有界数据，STREAMING执行模式可以用在有界数据和无界数据。

// 获取批式执行环境

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

// 读取数据

DataSource<String> dataSource = executionEnvironment.readTextFile("/root/tmp.data.log");

// 获取流式执行环境（有界流）

StreamExecutionEnvironment env= StreamExecutionEnvironment.getExecutionEnvironment();

// 读取数据

DataStreamSource<String> streamSource = env.readTextFile("/root/tmp.data.log");

// 获取流式执行环境（无界流）

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

// 读取数据

DataStreamSource<String> source = env.socketTextStream("host-master", 7777)

// 设置为批处理模式（默认流处理模式），其它代码不用修改

env.setRuntimeMode(RuntimeExecutionMode.BATCH);