flink,Environment的四种创建方式
时间: 2024-05-11 07:18:09 浏览: 115
flink安装包以及wordcount
Flink提供了四种创建Execution Environment的方式:
1. LocalExecutionEnvironment:用于本地调试和测试。可以通过以下方式创建:
```java
ExecutionEnvironment env = ExecutionEnvironment.createLocalEnvironment();
```
2. RemoteExecutionEnvironment:用于连接到远程Flink集群。可以通过以下方式创建:
```java
ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment("host", port, "path/to/jar");
```
3. StreamExecutionEnvironment:用于流处理。可以通过以下方式创建:
```java
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
```
4. BatchExecutionEnvironment:用于批处理。可以通过以下方式创建:
```java
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
```
其中,第3种和第4种方式都是通过静态方法获取Execution Environment的实例,而第1种和第2种方式则是通过构造方法创建Execution Environment的实例。
阅读全文