Package org.apache.beam.runners.flink

package org.apache.beam.runners.flink

Internal implementation of the Beam runner for Apache Flink.

Related Packages

Package	Description
org.apache.beam.runners.flink.adapter	Adaptors for using Beam transforms in Apache Flink pipelines.
org.apache.beam.runners.flink.metrics	Internal metrics implementation of the Beam runner for Apache Flink.

Class	Description
FlinkBatchPortablePipelineTranslator	A translator that translates bounded portable pipelines into executable Flink pipelines.
FlinkBatchPortablePipelineTranslator.BatchTranslationContext	Batch translation context.
FlinkBatchPortablePipelineTranslator.IsFlinkNativeTransform	Predicate to determine whether a URN is a Flink native transform.
FlinkBatchPortablePipelineTranslator.PTransformTranslator	Transform translation interface.
FlinkDetachedRunnerResult	Result of a detached execution of a Pipeline with Flink.
FlinkExecutionEnvironments	Utilities for Flink execution environments.
FlinkJobInvoker	Job Invoker for the FlinkRunner.
FlinkJobServerDriver	Driver program that starts a job server for the Flink runner.
FlinkJobServerDriver.FlinkServerConfiguration	Flink runner-specific Configuration for the jobServer.
FlinkMiniClusterEntryPoint	Entry point for starting an embedded Flink cluster.
FlinkPipelineOptions	Options which can be used to configure the Flink Runner.
FlinkPipelineOptions.MaxBundleSizeFactory	Maximum bundle size factory.
FlinkPipelineOptions.MaxBundleTimeFactory	Maximum bundle time factory.
FlinkPipelineRunner	Runs a Pipeline on Flink via FlinkRunner.
FlinkPortableClientEntryPoint	Flink job entry point to launch a Beam pipeline by executing an external SDK driver program.
FlinkPortablePipelineTranslator<T extends FlinkPortablePipelineTranslator.TranslationContext>	Interface for portable Flink translators.
FlinkPortablePipelineTranslator.Executor	A handle used to execute a translated pipeline.
FlinkPortablePipelineTranslator.TranslationContext	The context used for pipeline translation.
FlinkPortableRunnerResult	Result of executing a portable 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.
FlinkStateBackendFactory	Constructs a StateBackend to use from flink pipeline options.
FlinkStreamingAggregationsTranslators
FlinkStreamingAggregationsTranslators.ConcatenateAsIterable<T>
FlinkStreamingPortablePipelineTranslator	Translate an unbounded portable pipeline representation into a Flink pipeline representation.
FlinkStreamingPortablePipelineTranslator.IsFlinkNativeTransform	Predicate to determine whether a URN is a Flink native transform.
FlinkStreamingPortablePipelineTranslator.PTransformTranslator<T>
FlinkStreamingPortablePipelineTranslator.StreamingTranslationContext	Streaming translation context.
TestFlinkRunner	Test Flink runner.
VersionDependentFlinkPipelineOptions