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 LocalFlinkMiniCluster |
cluster |
protected static int |
DEFAULT_PARALLELISM |
protected static org.slf4j.Logger |
LOG |
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 |
---|
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 LocalFlinkMiniCluster cluster
protected static final org.slf4j.Logger LOG
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.