Package | Description |
---|---|
org.apache.flink.connector.testframe.container | |
org.apache.flink.test.util | |
org.apache.flink.tests.util.flink |
Class and Description |
---|
JobSubmission
Programmatic definition of a job-submission.
|
SQLJobSubmission
Programmatic definition of a SQL job-submission.
|
Class and Description |
---|
AbstractTestBase
Base class for unit tests that run multiple tests and want to reuse the same Flink cluster.
|
JobSubmission
Programmatic definition of a job-submission.
|
JobSubmission.JobSubmissionBuilder
Builder for the
JobSubmission . |
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.
|
ShellScript.ShellScriptBuilder
Builder to create shell script.
|
SQLJobSubmission
Programmatic definition of a SQL job-submission.
|
SQLJobSubmission.ClientMode
Use which client to submit job.
|
SQLJobSubmission.SQLJobSubmissionBuilder
Builder for the
SQLJobSubmission . |
TestEnvironment
A
ExecutionEnvironment implementation which executes its jobs on a MiniCluster . |
TestProcessBuilder
Utility class wrapping
ProcessBuilder and pre-configuring it with common options. |
TestProcessBuilder.TestProcess
Process with it's processOutput . |
Class and Description |
---|
JobSubmission
Programmatic definition of a job-submission.
|
SQLJobSubmission
Programmatic definition of a SQL job-submission.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.