Package | Description |
---|---|
org.apache.flink.test.util |
Class and Description |
---|
AbstractTestBase
Base class for unit tests that run multiple tests and want to reuse the same
Flink cluster.
|
MiniClusterResourceConfiguration
Deprecated.
This class should be replaced with
MiniClusterResourceConfiguration . |
MiniClusterResourceConfiguration.Builder
Deprecated.
Builder for
MiniClusterResourceConfiguration . |
MiniClusterWithClientResource
Starts a Flink mini cluster as a resource and registers the respective
ExecutionEnvironment and StreamExecutionEnvironment.
|
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
Utility class containing various methods for testing purposes.
|
TestEnvironment
A
ExecutionEnvironment implementation which executes its jobs on a
MiniCluster . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.