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

@DefaultAnnotation(org.apache.beam.buildtools.NonnullByDefault.class) package org.apache.beam.runners.flink.translation.wrappers.streaming.stableinput

Classes for buffering elements for achieving @RequiresStableInput.

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.state	Internal state implementation of the Beam runner for Apache Flink.

Class	Description
BufferedElement	An interface for elements buffered during a checkpoint when using @RequiresStableInput.
BufferingDoFnRunner<InputT,OutputT>	A DoFnRunner which buffers data for supporting DoFn.RequiresStableInput.
KeyedBufferingElementsHandler	A keyed implementation of a BufferingElementsHandler.
NonKeyedBufferingElementsHandler<T>	A non-keyed implementation of a BufferingElementsHandler.