public abstract class StreamingProgramTestBase extends AbstractTestBase
TestBaseUtils.TupleComparator<T extends Tuple>
Modifier and Type | Field and Description |
---|---|
protected static int |
DEFAULT_PARALLELISM |
config, executor, numTaskManagers, taskManagerNumSlots, temporaryFolder
DEFAULT_AKKA_ASK_TIMEOUT, DEFAULT_AKKA_STARTUP_TIMEOUT, DEFAULT_TIMEOUT, logDir, MINIMUM_HEAP_SIZE_MB, TASK_MANAGER_MEMORY_SIZE
log, watchman
Constructor and Description |
---|
StreamingProgramTestBase() |
Modifier and Type | Method and Description |
---|---|
int |
getParallelism() |
protected void |
postSubmit() |
protected void |
preSubmit() |
void |
setParallelism(int parallelism) |
void |
testJob() |
protected abstract void |
testProgram() |
createAndRegisterTempFile, createTempFile, getNumTaskManagers, getTaskManagerNumSlots, getTempDirPath, getTempFilePath, setNumTaskManagers, setTaskManagerNumSlots, startCluster, stopCluster
asFile, checkLinesAgainstRegexp, compareKeyValuePairsWithDelta, compareKeyValuePairsWithDelta, compareOrderedResultAsText, compareOrderedResultAsText, compareResultAsText, compareResultAsTuples, compareResultCollections, compareResultsByLinesInMemory, compareResultsByLinesInMemory, compareResultsByLinesInMemoryWithStrictOrder, compareResultsByLinesInMemoryWithStrictOrder, constructTestPath, constructTestURI, containsResultAsText, deleteRecursively, getFromHTTP, getResultInputStream, getResultInputStream, getResultReader, getResultReader, readAllResultLines, readAllResultLines, readAllResultLines, setEnv, startCluster, startCluster, stopCluster, toParameterList, toParameterList
protected static final int DEFAULT_PARALLELISM
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.