| AbstractTestBase |
Base class for unit tests that run multiple tests and want to reuse the same Flink cluster.
|
| AbstractTestBaseJUnit4 |
Deprecated.
|
| JobSubmission |
Programmatic definition of a job-submission.
|
| JobSubmission.JobSubmissionBuilder |
|
| MiniClusterWithClientResource |
Starts a Flink mini cluster as a resource and registers the 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.
|
| MultipleProgramsTestBaseJUnit4.TestExecutionMode |
Deprecated.
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.
|
| SQLJobClientMode |
Use which client to submit job.
|
| SQLJobClientMode.EmbeddedSqlClient |
Use the Sql Client embedded mode to submit jobs.
|
| SQLJobClientMode.GatewayClientMode |
The base gateway mode to submit jobs.
|
| SQLJobClientMode.GatewaySqlClient |
Uses the Sql Client gateway mode to submit jobs.
|
| SQLJobClientMode.HiveJDBC |
Uses the Hive JDBC to submit jobs.
|
| SQLJobClientMode.RestClient |
Uses a REST Client to submit jobs.
|
| SQLJobSubmission |
Programmatic definition of a SQL job-submission.
|
| SQLJobSubmission.SQLJobSubmissionBuilder |
|
| TestProcessBuilder |
Utility class wrapping ProcessBuilder and pre-configuring it with common options.
|
| TestProcessBuilder.TestProcess |
|