public class StreamingMultipleProgramsTestBase extends AbstractTestBase
To write a unit test against this test base, simply extend it and add one or more regular test methods and retrieve the StreamExecutionEnvironment from the context:
@Test public void someTest() { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); // test code env.execute(); } @Test public void anotherTest() { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); // test code env.execute(); }
TestBaseUtils.TupleComparator<T extends Tuple>
Modifier and Type | Field and Description |
---|---|
protected static org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster |
cluster |
protected static int |
DEFAULT_PARALLELISM |
protected static org.slf4j.Logger |
LOG |
config, executor, numTaskManagers, taskManagerNumSlots, 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 |
---|
StreamingMultipleProgramsTestBase() |
Modifier and Type | Method and Description |
---|---|
static void |
setup() |
static void |
teardown() |
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, getFromHTTP, getResultInputStream, getResultInputStream, getResultReader, getResultReader, readAllResultLines, readAllResultLines, readAllResultLines, setEnv, startCluster, startCluster, stopCluster, toParameterList, toParameterList
protected static final int DEFAULT_PARALLELISM
protected static org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster cluster
protected static final org.slf4j.Logger LOG
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.