Package org.apache.flink.test.util

Class Summary

Class	Description
AbstractTestBase	A base class for tests that run test programs in a Flink mini cluster.
CollectionTestEnvironment	A CollectionEnvironment to be used in tests.
JavaProgramTestBase	Base class for unit tests that run a single test with object reuse enabled/disabled and against collection environments.
MultipleProgramsTestBase	Base class for unit tests that run multiple tests and want to reuse the same Flink cluster.
SecureTestEnvironment	Helper SecureTestEnvironment to handle MiniKDC lifecycle.
TestBaseUtils	Utility class containing various methods for testing purposes.
TestBaseUtils.TupleComparator<T extends Tuple>	Comparator for comparable Tuples.
TestEnvironment	A ExecutionEnvironment implementation which executes its jobs on a LocalFlinkMiniCluster.
TestingSecurityContext	Test security context to support handling both client and server principals in MiniKDC.

Enum Summary

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.