org.apache.flink.streaming.api.environment

Class LegacyLocalStreamEnvironment

java.lang.Object

org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

org.apache.flink.streaming.api.environment.LocalStreamEnvironment

org.apache.flink.streaming.api.environment.LegacyLocalStreamEnvironment

@Public
public class LegacyLocalStreamEnvironment
extends LocalStreamEnvironment

The LocalStreamEnvironment is a StreamExecutionEnvironment that runs the program locally, multi-threaded, in the JVM where the environment is instantiated. It spawns an embedded Flink cluster in the background and executes the program on that cluster.

When this environment is instantiated, it uses a default parallelism of 1. The default parallelism can be set via StreamExecutionEnvironment.setParallelism(int).

Local environments can also be instantiated through StreamExecutionEnvironment.createLocalEnvironment() and StreamExecutionEnvironment.createLocalEnvironment(int). The former version will pick a default parallelism equal to the number of hardware contexts in the local machine.

Field Summary

Fields inherited from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

cacheFile, DEFAULT_JOB_NAME, isChainingEnabled, transformations

Constructor Summary

Constructors

Constructor and Description
LegacyLocalStreamEnvironment()
LegacyLocalStreamEnvironment(org.apache.flink.configuration.Configuration config) Creates a new local stream environment that configures its local executor with the given configuration.

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.common.JobExecutionResult	execute(String jobName) Executes the JobGraph of the on a mini cluster of CLusterUtil with a user specified name.

Methods inherited from class org.apache.flink.streaming.api.environment.LocalStreamEnvironment

getConfiguration

Methods inherited from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment

addDefaultKryoSerializer, addDefaultKryoSerializer, addOperator, addSource, addSource, addSource, addSource, clean, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, disableOperatorChaining, enableCheckpointing, enableCheckpointing, enableCheckpointing, enableCheckpointing, execute, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getBufferTimeout, getCachedFiles, getCheckpointConfig, getCheckpointingMode, getCheckpointInterval, getConfig, getDefaultLocalParallelism, getExecutionEnvironment, getExecutionPlan, getMaxParallelism, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getStateBackend, getStreamGraph, getStreamTimeCharacteristic, initializeContextEnvironment, isChainingEnabled, isForceCheckpointing, readFile, readFile, readFile, readFile, readFileStream, readTextFile, readTextFile, registerCachedFile, registerCachedFile, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setBufferTimeout, setDefaultLocalParallelism, setMaxParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy, setStateBackend, setStateBackend, setStreamTimeCharacteristic, socketTextStream, socketTextStream, socketTextStream, socketTextStream, socketTextStream

Methods inherited from class java.lang.Object

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

Constructor Detail

LegacyLocalStreamEnvironment

public LegacyLocalStreamEnvironment()

LegacyLocalStreamEnvironment

public LegacyLocalStreamEnvironment(org.apache.flink.configuration.Configuration config)

Creates a new local stream environment that configures its local executor with the given configuration.

Parameters:

config - The configuration used to configure the local executor.

Method Detail

execute

public org.apache.flink.api.common.JobExecutionResult execute(String jobName)
                                                       throws Exception

Executes the JobGraph of the on a mini cluster of CLusterUtil with a user specified name.

Overrides:

execute in class LocalStreamEnvironment

Parameters:

jobName - name of the job

Returns:

The result of the job execution, containing elapsed time and accumulators.

Throws:

Exception - which occurs during job execution.