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.
-
ClassesClassDescriptionHelpers for reporting checkpoint durations.Pipeline visitors that fills a lookup table of
PValue
to number of consumers.Various utilies related to portability.Pipeline visitor that fills lookup table ofPTransform
toAppliedPTransform
for usage inFlinkBatchPortablePipelineTranslator.BatchTranslationContext
.Util methods to help with serialization / deserialization.Workarounds for dealing with limitations of Flink or its libraries.