Class | Description |
---|---|
AbstractTestBase |
A base class for tests that run test programs in a Flink mini cluster.
|
CollectionTestEnvironment | |
ForkableFlinkMiniCluster |
A forkable mini cluster is a special case of the mini cluster, used for parallel test execution
on build servers.
|
ForkableFlinkMiniCluster$ | |
JavaProgramTestBase | |
JavaProgramTestBase.TupleComparator<T extends Tuple> | |
MultipleProgramsTestBase |
Base class for unit tests that run multiple tests and want to reuse the same
Flink cluster.
|
TestBaseUtils | |
TestBaseUtils.TupleComparator<T extends Tuple> | |
TestEnvironment |
Enum | Description |
---|---|
MultipleProgramsTestBase.TestExecutionMode |
Enum that defines which execution environment to run the next test on:
An embedded local flink cluster, or the collection execution backend.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.