Package org.apache.flink.tests.util.flink
-
Interface Summary Interface Description ClusterController Controller for interacting with a cluster.FlinkResource Generic interface for interacting with Flink.FlinkResourceFactory A factory forFlinkResource
implementations.GatewayController Controller for interacting with a SqlGateway.JobController Controller for interacting with a job. -
Class Summary Class Description FlinkDistribution A wrapper around a Flink distribution.FlinkDistribution.TestSqlGatewayRestClient This rest client is used to submit SQL strings to Rest Endpoint of Sql Gateway.FlinkResourceSetup Setup instructions for aFlinkResource
.FlinkResourceSetup.FlinkResourceSetupBuilder Builder forFlinkResourceSetup
.LocalStandaloneFlinkResource Flink resource that start local standalone clusters.LocalStandaloneFlinkResourceFactory AFlinkResourceFactory
for theLocalStandaloneFlinkResource
. -
Enum Summary Enum Description JarLocation Enum for specifying jar locations.