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

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

Internal implementation of the Beam runner for Apache Flink.

Classes

Class	Description
CoderTypeInformation<T>	Flink TypeInformation for Beam Coders.
CoderTypeSerializer<T>	Flink TypeSerializer for Beam Coders.
EncodedValueComparator	Flink TypeComparator for Beam values that have been encoded to byte data by a Coder.
EncodedValueSerializer	TypeSerializer for values that were encoded using a Coder.
EncodedValueTypeInformation	Flink TypeInformation for Beam values that have been encoded to byte data by a Coder.
KvKeySelector<InputT,K>	KeySelector that extracts the key from a KV and returns it in encoded form as a byte array.
UnversionedTypeSerializerSnapshot<T>	A legacy snapshot which does not care about schema compatibility.
WindowedKvKeySelector<InputT,K>	KeySelector that extracts the key from a KV and returns it in encoded form as a byte array.