public class StreamingMultipleProgramsTestBase extends AbstractTestBase
@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 ForkableFlinkMiniCluster |
cluster |
protected static int |
DEFAULT_PARALLELISM |
config, executor, numTaskManagers, taskManagerNumSlots
DEFAULT_AKKA_ASK_TIMEOUT, DEFAULT_AKKA_STARTUP_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, getResultInputStream, getResultInputStream, getResultReader, getResultReader, readAllResultLines, readAllResultLines, readAllResultLines, setEnv, startCluster, startCluster, stopCluster, toParameterList, toParameterList
protected static final int DEFAULT_PARALLELISM
protected static ForkableFlinkMiniCluster cluster
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.