org.apache.flink.test.util

Class CollectionTestEnvironment

java.lang.Object

org.apache.flink.api.java.ExecutionEnvironment

org.apache.flink.api.java.CollectionEnvironment

org.apache.flink.test.util.CollectionTestEnvironment

public class CollectionTestEnvironment
extends CollectionEnvironment

A CollectionEnvironment to be used in tests. The predominant feature of this class is that it allows setting it as a context environment, causing it to be returned by ExecutionEnvironment.getExecutionEnvironment(). This also allows retrieving the JobExecutionResult outside the actual program.

Field Summary

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

jobID, lastJobExecutionResult, LOG, sessionTimeout

Constructor Summary

Constructors

Constructor and Description
CollectionTestEnvironment()

Method Summary

Modifier and Type	Method and Description
JobExecutionResult	execute() Triggers the program execution.
JobExecutionResult	execute(String jobName) Triggers the program execution.
JobExecutionResult	getLastJobExecutionResult() Returns the JobExecutionResult of the last executed job.
protected void	setAsContext()
protected static void	unsetAsContext()

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

getExecutionPlan, getParallelism, startNewSession

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

addDefaultKryoSerializer, addDefaultKryoSerializer, areExplicitEnvironmentsAllowed, createCollectionsEnvironment, createInput, createInput, createLocalEnvironment, createLocalEnvironment, createLocalEnvironment, createLocalEnvironmentWithWebUI, createProgramPlan, createProgramPlan, createProgramPlan, createRemoteEnvironment, createRemoteEnvironment, createRemoteEnvironment, fromCollection, fromCollection, fromCollection, fromCollection, fromElements, fromElements, fromParallelCollection, fromParallelCollection, generateSequence, getConfig, getDefaultLocalParallelism, getExecutionEnvironment, getId, getIdString, getNumberOfExecutionRetries, getRestartStrategy, getSessionTimeout, initializeContextEnvironment, readCsvFile, readFile, readFileOfPrimitives, readFileOfPrimitives, readTextFile, readTextFile, readTextFileWithValue, readTextFileWithValue, registerCachedFile, registerCachedFile, registerCachedFilesWithPlan, registerType, registerTypeWithKryoSerializer, registerTypeWithKryoSerializer, resetContextEnvironment, setDefaultLocalParallelism, setNumberOfExecutionRetries, setParallelism, setRestartStrategy, setSessionTimeout

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectionTestEnvironment

public CollectionTestEnvironment()

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.

execute

public JobExecutionResult execute()
                           throws Exception

Description copied from class: ExecutionEnvironment

Triggers the program execution. The environment will execute all parts of the program that have resulted in a "sink" operation. Sink operations are for example printing results (DataSet.print(), writing results (e.g. DataSet.writeAsText(String), DataSet.write(org.apache.flink.api.common.io.FileOutputFormat, String), or other generic data sinks created with DataSet.output(org.apache.flink.api.common.io.OutputFormat).

The program execution will be logged and displayed with a generated default name.

Overrides:

execute in class ExecutionEnvironment

Returns:

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

Throws:

Exception - Thrown, if the program executions fails.

execute

public JobExecutionResult execute(String jobName)
                           throws Exception

Description copied from class: ExecutionEnvironment

Triggers the program execution. The environment will execute all parts of the program that have resulted in a "sink" operation. Sink operations are for example printing results (DataSet.print(), writing results (e.g. DataSet.writeAsText(String), DataSet.write(org.apache.flink.api.common.io.FileOutputFormat, String), or other generic data sinks created with DataSet.output(org.apache.flink.api.common.io.OutputFormat).

The program execution will be logged and displayed with the given job name.

Overrides:

execute in class CollectionEnvironment

Returns:

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

Throws:

Exception - Thrown, if the program executions fails.

setAsContext

protected void setAsContext()

unsetAsContext

protected static void unsetAsContext()