Package org.apache.beam.runners.flink.translation.wrappers.streaming.state

package org.apache.beam.runners.flink.translation.wrappers.streaming.state

Internal state implementation of the Beam runner for Apache Flink.

Related Packages

Package	Description
org.apache.beam.runners.flink.translation.wrappers.streaming	Internal implementation of the Beam runner for Apache Flink.
org.apache.beam.runners.flink.translation.wrappers.streaming.io	Internal implementation of the Beam runner for Apache Flink.
org.apache.beam.runners.flink.translation.wrappers.streaming.stableinput	Classes for buffering elements for achieving @RequiresStableInput.

Classes

Class	Description
FlinkBroadcastStateInternals<K>	StateInternals that uses a Flink OperatorStateBackend to manage the broadcast state.
FlinkStateInternals<K>	StateInternals that uses a Flink KeyedStateBackend to manage state.
FlinkStateInternals.EarlyBinder	Eagerly create user state to work around https://jira.apache.org/jira/browse/FLINK-12653.
FlinkStateInternals.FlinkStateNamespaceKeySerializer
FlinkStateInternals.FlinkStateNamespaceKeySerializer.FlinkStateNameSpaceSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.