org.apache.flink.test.util

Class JavaProgramTestBase

java.lang.Object

org.apache.flink.util.TestLogger

org.apache.flink.test.util.TestBaseUtils

org.apache.flink.test.util.AbstractTestBase

org.apache.flink.test.util.JavaProgramTestBase

public abstract class JavaProgramTestBase
extends AbstractTestBase

Base class for unit tests that run a single test with object reuse enabled/disabled and against collection environments.

To write a unit test against this test base, simply extend it and implement the testProgram() method.

To skip the execution against collection environments you have to override skipCollectionExecution().

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.test.util.TestBaseUtils

TestBaseUtils.TupleComparator<T extends Tuple>

Field Summary

Fields inherited from class org.apache.flink.test.util.AbstractTestBase

config, executor, numTaskManagers, taskManagerNumSlots, TEMPORARY_FOLDER

Fields inherited from class org.apache.flink.test.util.TestBaseUtils

DEFAULT_AKKA_ASK_TIMEOUT, DEFAULT_AKKA_STARTUP_TIMEOUT, DEFAULT_HTTP_TIMEOUT, DEFAULT_TIMEOUT, logDir, MINIMUM_HEAP_SIZE_MB, TASK_MANAGER_MEMORY_SIZE

Fields inherited from class org.apache.flink.util.TestLogger

log, watchman

Constructor Summary

Constructors

Constructor and Description
JavaProgramTestBase()
JavaProgramTestBase(Configuration config)

Method Summary

Modifier and Type	Method and Description
JobExecutionResult	getLatestExecutionResult()
int	getParallelism()
boolean	isCollectionExecution()
protected void	postSubmit()
protected void	preSubmit()
void	setNumberOfTestRepetitions(int numberOfTestRepetitions)
void	setParallelism(int parallelism)
protected boolean	skipCollectionExecution()
void	testJobCollectionExecution()
void	testJobWithObjectReuse()
void	testJobWithoutObjectReuse()
protected abstract void	testProgram()

Methods inherited from class org.apache.flink.test.util.AbstractTestBase

createAndRegisterTempFile, createTempFile, getNumTaskManagers, getTaskManagerNumSlots, getTempDirPath, getTempFilePath, setNumTaskManagers, setTaskManagerNumSlots, startCluster, stopCluster

Methods inherited from class org.apache.flink.test.util.TestBaseUtils

asFile, checkLinesAgainstRegexp, compareKeyValuePairsWithDelta, compareKeyValuePairsWithDelta, compareOrderedResultAsText, compareOrderedResultAsText, compareResultAsText, compareResultAsTuples, compareResultCollections, compareResultsByLinesInMemory, compareResultsByLinesInMemory, compareResultsByLinesInMemoryWithStrictOrder, compareResultsByLinesInMemoryWithStrictOrder, constructTestPath, constructTestURI, containsResultAsText, deleteRecursively, getFromHTTP, getFromHTTP, getResultInputStream, getResultInputStream, getResultReader, getResultReader, readAllResultLines, readAllResultLines, readAllResultLines, setEnv, startCluster, startCluster, stopCluster, toParameterList, toParameterList

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaProgramTestBase

public JavaProgramTestBase()

JavaProgramTestBase

public JavaProgramTestBase(Configuration config)

Method Detail

setParallelism

public void setParallelism(int parallelism)

setNumberOfTestRepetitions

public void setNumberOfTestRepetitions(int numberOfTestRepetitions)

getParallelism

public int getParallelism()

getLatestExecutionResult

public JobExecutionResult getLatestExecutionResult()

isCollectionExecution

public boolean isCollectionExecution()

testProgram

protected abstract void testProgram()
                             throws Exception

Throws:

Exception

preSubmit

protected void preSubmit()
                  throws Exception

Throws:

Exception

postSubmit

protected void postSubmit()
                   throws Exception

Throws:

Exception

skipCollectionExecution

protected boolean skipCollectionExecution()

testJobWithObjectReuse

public void testJobWithObjectReuse()
                            throws Exception

Throws:

Exception

testJobWithoutObjectReuse

public void testJobWithoutObjectReuse()
                               throws Exception

Throws:

Exception

testJobCollectionExecution

public void testJobCollectionExecution()
                                throws Exception

Throws:

Exception