See: Description
| Interface | Description |
|---|---|
| FlinkPipelineOptions |
Options which can be used to configure a Flink PipelineRunner.
|
| FlinkPortablePipelineTranslator<T extends FlinkPortablePipelineTranslator.TranslationContext> |
Interface for portable Flink translators.
|
| FlinkPortablePipelineTranslator.TranslationContext |
The context used for pipeline translation.
|
| Class | Description |
|---|---|
| DefaultParallelismFactory |
DefaultValueFactory for getting a default value for the parallelism option on FlinkPipelineOptions. |
| FlinkBatchPortablePipelineTranslator |
A translator that translates bounded portable pipelines into executable Flink pipelines.
|
| FlinkBatchPortablePipelineTranslator.BatchTranslationContext |
Batch translation context.
|
| FlinkDetachedRunnerResult |
Result of a detached execution of a
Pipeline with Flink. |
| FlinkExecutionEnvironments |
Utilities for Flink execution environments.
|
| FlinkJobInvocation |
Invocation of a Flink Job via
FlinkRunner. |
| FlinkJobInvoker |
Job Invoker for the
FlinkRunner. |
| FlinkJobServerDriver |
Driver program that starts a job server.
|
| 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. |
| FlinkStreamingPortablePipelineTranslator |
Translate an unbounded portable pipeline representation into a Flink pipeline representation.
|
| FlinkStreamingPortablePipelineTranslator.StreamingTranslationContext |
Streaming translation context.
|
| FlinkTransformOverrides |
PTransform overrides for Flink runner. |
| TestFlinkRunner |
Test Flink runner.
|