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 |
|---|---|
| ArtifactSourcePool |
A pool of
ArtifactSources that can be used as a single source. |
| 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.
|
| 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.
|