Package | Description |
---|---|
org.apache.flink.tests.util.flink |
Class and Description |
---|
ClusterController
Controller for interacting with a cluster.
|
FlinkContainer
A container that wraps a Flink distribution and spawns a Flink cluster in a single Docker
container.
|
FlinkContainer.FlinkContainerBuilder
A builder for a
FlinkContainer . |
FlinkResource
Generic interface for interacting with Flink.
|
FlinkResourceFactory
A factory for
FlinkResource implementations. |
FlinkResourceSetup
Setup instructions for a
FlinkResource . |
FlinkResourceSetup.FlinkResourceSetupBuilder
Builder for
FlinkResourceSetup . |
JarLocation
Enum for specifying jar locations.
|
JobController
Controller for interacting with a job.
|
JobSubmission
Programmatic definition of a job-submission.
|
JobSubmission.JobSubmissionBuilder
Builder for the
JobSubmission . |
SQLJobSubmission
Programmatic definition of a SQL job-submission.
|
SQLJobSubmission.SQLJobSubmissionBuilder
Builder for the
SQLJobSubmission . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.