Class | Description |
---|---|
AbstractTestBase |
Base class for unit tests that run multiple tests and want to reuse the same Flink 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.
|
MiniClusterResource | Deprecated
This class should be replaced with
MiniClusterWithClientResource . |
MiniClusterResourceConfiguration | Deprecated
This class should be replaced with
MiniClusterResourceConfiguration . |
MiniClusterResourceConfiguration.Builder |
Builder for
MiniClusterResourceConfiguration . |
MiniClusterWithClientResource |
Starts a Flink mini cluster as a resource and registers the respective ExecutionEnvironment and
StreamExecutionEnvironment.
|
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. |
ShellScript |
ShellScript for creating shell script on linux and windows.
|
ShellScript.ShellScriptBuilder |
Builder to create shell script.
|
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 MiniCluster . |
TestingSecurityContext |
Test security context to support handling both client and server principals in MiniKDC.
|
TestProcessBuilder |
Utility class wrapping
ProcessBuilder and pre-configuring it with common options. |
TestProcessBuilder.TestProcess |
Process with it's processOutput . |
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–2021 The Apache Software Foundation. All rights reserved.