Package org.apache.beam.runners.flink.translation.utils

package org.apache.beam.runners.flink.translation.utils

Internal implementation of the Beam runner for Apache Flink.

Classes

Class	Description
CheckpointStats	Helpers for reporting checkpoint durations.
CountingPipelineVisitor	Pipeline visitors that fills a lookup table of PValue to number of consumers.
FlinkPortableRunnerUtils	Various utilies related to portability.
Locker
LookupPipelineVisitor	Pipeline visitor that fills lookup table of PTransform to AppliedPTransform for usage in FlinkBatchPortablePipelineTranslator.BatchTranslationContext.
SerdeUtils	Util methods to help with serialization / deserialization.
Workarounds	Workarounds for dealing with limitations of Flink or its libraries.