public abstract class StreamingProgramTestBase extends AbstractTestBase
To write a unit test against this test base, simply extend it and implement the testProgram()
method.
TestBaseUtils.TupleComparator<T extends Tuple>
miniClusterResource, TEMPORARY_FOLDER
DEFAULT_AKKA_ASK_TIMEOUT, DEFAULT_AKKA_STARTUP_TIMEOUT, DEFAULT_HTTP_TIMEOUT, DEFAULT_TIMEOUT, logDir, MINIMUM_HEAP_SIZE_MB, TASK_MANAGER_MEMORY_SIZE
log, watchman
Constructor and Description |
---|
StreamingProgramTestBase() |
Modifier and Type | Method and Description |
---|---|
protected void |
postSubmit() |
protected void |
preSubmit() |
void |
testJob() |
protected abstract void |
testProgram() |
createAndRegisterTempFile, createTempFile, getTempDirPath, getTempFilePath
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
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.