org.apache.flink.test.util

Class TestEnvironment

java.lang.Object

org.apache.flink.api.java.ExecutionEnvironment

org.apache.flink.test.util.TestEnvironment

public class TestEnvironment
extends ExecutionEnvironment

A ExecutionEnvironment implementation which executes its jobs on a MiniCluster.

Field Summary

Fields inherited from class org.apache.flink.api.java.ExecutionEnvironment

lastJobExecutionResult, LOG

Constructor Summary

Constructors

Constructor and Description
TestEnvironment(MiniCluster executor, int parallelism, boolean isObjectReuseEnabled)
TestEnvironment(MiniCluster miniCluster, int parallelism, boolean isObjectReuseEnabled, Collection<Path> jarFiles, Collection<URL> classPaths)

Method Summary

Modifier and Type	Method and Description
JobExecutionResult	getLastJobExecutionResult() Returns the JobExecutionResult of the last executed job.
void	setAsContext()
static void	setAsContext(MiniCluster miniCluster, int parallelism) Sets the current ExecutionEnvironment to be a TestEnvironment.
static void	setAsContext(MiniCluster miniCluster, int parallelism, Collection<Path> jarFiles, Collection<URL> classPaths) Sets the current ExecutionEnvironment to be a TestEnvironment.
static void	unsetAsContext()

Methods inherited from class org.apache.flink.api.java.ExecutionEnvironment

addDefaultKryoSerializer, addDefaultKryoSerializer, areExplicitEnvironmentsAllowed, clearJobListeners, configure, createCollectionsEnvironment, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createProgramPlan, createProgramPlan, createProgramPlan, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, execute, execute, executeAsync, executeAsync, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getConfig, getConfiguration, getDefaultLocalParallelism, getExecutionEnvironment, getExecutionPlan, getExecutorServiceLoader, getJobListeners, getNumberOfExecutionRetries, getParallelism, getRestartStrategy, getUserCodeClassLoader, initializeContextEnvironment, readCsvFile, readFile, readFileOfPrimitives, readFileOfPrimitives, readTextFile, readTextFile, readTextFileWithValue, readTextFileWithValue, registerCachedFile, registerCachedFile, registerJobListener, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setDefaultLocalParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy

Methods inherited from class java.lang.Object

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

Constructor Detail

TestEnvironment

public TestEnvironment(MiniCluster miniCluster,
                       int parallelism,
                       boolean isObjectReuseEnabled,
                       Collection<Path> jarFiles,
                       Collection<URL> classPaths)

TestEnvironment

public TestEnvironment(MiniCluster executor,
                       int parallelism,
                       boolean isObjectReuseEnabled)

Method Detail

getLastJobExecutionResult

public JobExecutionResult getLastJobExecutionResult()

Description copied from class: ExecutionEnvironment

Returns the JobExecutionResult of the last executed job.

Overrides:

getLastJobExecutionResult in class ExecutionEnvironment

Returns:

The execution result from the latest job execution.

setAsContext

public void setAsContext()

setAsContext

public static void setAsContext(MiniCluster miniCluster,
                                int parallelism,
                                Collection<Path> jarFiles,
                                Collection<URL> classPaths)

Sets the current ExecutionEnvironment to be a TestEnvironment. The test environment executes the given jobs on a Flink mini cluster with the given default parallelism and the additional jar files and class paths.

Parameters:

miniCluster - The MiniCluster to execute jobs on.

parallelism - The default parallelism

jarFiles - Additional jar files to execute the job with

classPaths - Additional class paths to execute the job with

setAsContext

public static void setAsContext(MiniCluster miniCluster,
                                int parallelism)

Sets the current ExecutionEnvironment to be a TestEnvironment. The test environment executes the given jobs on a Flink mini cluster with the given default parallelism and the additional jar files and class paths.

Parameters:

miniCluster - The MiniCluster to execute jobs on.

parallelism - The default parallelism

unsetAsContext

public static void unsetAsContext()