| 程序包 | 说明 |
|---|---|
| org.apache.flink.datastream.impl | |
| org.apache.flink.datastream.impl.stream |
| 限定符和类型 | 类和说明 |
|---|---|
class |
ExecutionContextEnvironment
Special
ExecutionEnvironment that will be used in cases where the CLI client or testing
utilities create a ExecutionEnvironment that should be used when ExecutionEnvironment.getInstance() ()} is called. |
| 限定符和类型 | 字段和说明 |
|---|---|
protected ExecutionEnvironmentImpl |
ProcessConfigureHandle.environment |
protected ExecutionEnvironmentImpl |
AbstractDataStream.environment |
| 限定符和类型 | 方法和说明 |
|---|---|
ExecutionEnvironmentImpl |
AbstractDataStream.getEnvironment() |
| 构造器和说明 |
|---|
AbstractDataStream(ExecutionEnvironmentImpl environment,
org.apache.flink.api.dag.Transformation<T> transformation) |
BroadcastStreamImpl(ExecutionEnvironmentImpl environment,
org.apache.flink.api.dag.Transformation<T> transformation) |
GlobalStreamImpl(ExecutionEnvironmentImpl environment,
org.apache.flink.api.dag.Transformation<T> transformation) |
NonKeyedPartitionStreamImpl(ExecutionEnvironmentImpl environment,
org.apache.flink.api.dag.Transformation<T> transformation) |
ProcessConfigureHandle(ExecutionEnvironmentImpl environment,
org.apache.flink.api.dag.Transformation<T> transformation) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.