See: Description
| Interface | Description |
|---|---|
| FlinkPipelineOptions |
Options which can be used to configure a Flink PipelineRunner.
|
| Class | Description |
|---|---|
| DefaultParallelismFactory |
DefaultValueFactory for getting a default value for the parallelism option
on FlinkPipelineOptions. |
| FlinkDetachedRunnerResult |
Result of a detached execution of a
Pipeline with Flink. |
| FlinkRunner |
A
PipelineRunner that executes the operations in the
pipeline by first translating them to a Flink Plan and then executing them either locally
or on a Flink cluster, depending on the configuration. |
| FlinkRunnerRegistrar |
AutoService registrar - will register FlinkRunner and FlinkOptions
as possible pipeline runner services.
|
| FlinkRunnerRegistrar.Options |
Pipeline options registrar.
|
| FlinkRunnerRegistrar.Runner |
Pipeline runner registrar.
|
| FlinkRunnerResult |
Result of executing a
Pipeline with Flink. |
| FlinkTransformOverrides |
PTransform overrides for Flink runner. |
| TestFlinkRunner |
Test Flink runner.
|