public class MultipleProgramsTestBase extends TestBaseUtils
{@literal @}Test
public void someTest() {
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
// test code
env.execute();
}
{@literal @}Test
public void anotherTest() {
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
// test code
env.execute();
}
Modifier and Type | Class and Description |
---|---|
static class |
MultipleProgramsTestBase.TestExecutionMode
Enum that defines which execution environment to run the next test on:
An embedded local flink cluster, or the collection execution backend.
|
TestBaseUtils.TupleComparator<T extends Tuple>
Modifier and Type | Field and Description |
---|---|
protected static ForkableFlinkMiniCluster |
cluster |
protected static int |
DEFAULT_PARALLELISM |
protected MultipleProgramsTestBase.TestExecutionMode |
mode |
protected static boolean |
startWebServer |
DEFAULT_AKKA_ASK_TIMEOUT, DEFAULT_AKKA_STARTUP_TIMEOUT, DEFAULT_TIMEOUT, logDir, MINIMUM_HEAP_SIZE_MB, TASK_MANAGER_MEMORY_SIZE
log, watchman
Constructor and Description |
---|
MultipleProgramsTestBase(MultipleProgramsTestBase.TestExecutionMode mode) |
Modifier and Type | Method and Description |
---|---|
static Collection<Object[]> |
executionModes() |
static void |
setup() |
static void |
teardown() |
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 boolean startWebServer
protected static ForkableFlinkMiniCluster cluster
protected final MultipleProgramsTestBase.TestExecutionMode mode
public MultipleProgramsTestBase(MultipleProgramsTestBase.TestExecutionMode mode)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.