org.apache.beam.runners.flink

Class FlinkExecutionEnvironments

java.lang.Object

org.apache.beam.runners.flink.FlinkExecutionEnvironments

public class FlinkExecutionEnvironments
extends java.lang.Object

Utilities for Flink execution environments.

Constructor Summary

Constructors

Constructor and Description
FlinkExecutionEnvironments()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.api.java.ExecutionEnvironment	createBatchExecutionEnvironment(FlinkPipelineOptions options) If the submitted job is a batch processing job, this method creates the adequate Flink ExecutionEnvironment depending on the user-specified options.
static org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	createStreamExecutionEnvironment(FlinkPipelineOptions options, java.util.List<java.lang.String> filesToStage, @Nullable java.lang.String confDir) If the submitted job is a stream processing job, this method creates the adequate Flink StreamExecutionEnvironment depending on the user-specified options.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkExecutionEnvironments

public FlinkExecutionEnvironments()

Method Detail

createBatchExecutionEnvironment

public static org.apache.flink.api.java.ExecutionEnvironment createBatchExecutionEnvironment(FlinkPipelineOptions options)

If the submitted job is a batch processing job, this method creates the adequate Flink ExecutionEnvironment depending on the user-specified options.

createStreamExecutionEnvironment

public static org.apache.flink.streaming.api.environment.StreamExecutionEnvironment createStreamExecutionEnvironment(FlinkPipelineOptions options,
                                                                                                                     java.util.List<java.lang.String> filesToStage,
                                                                                                                     @Nullable java.lang.String confDir)

If the submitted job is a stream processing job, this method creates the adequate Flink StreamExecutionEnvironment depending on the user-specified options.