Package org.apache.beam.runners.jet.processors

Individual DAG node processors used by the Beam runner for Hazelcast Jet.

Class Summary

Class	Description
AssignWindowP<T>	/** * Jet Processor implementation for Beam's Windowing primitive.
BoundedSourceP<T>	Jet Processor implementation for reading from a bounded Beam source.
FlattenP	Jet Processor implementation for Beam's Flatten primitive.
FlattenP.Supplier	Jet Processor supplier that will provide instances of FlattenP.
ImpulseP	/** * Jet Processor implementation for Beam's Impulse primitive.
ParDoP<InputT,OutputT>	Jet Processor implementation for Beam's ParDo primitive (when no user-state is being used).
ParDoP.Supplier<InputT,OutputT>	Jet Processor supplier that will provide instances of ParDoP.
StatefulParDoP<OutputT>	Jet Processor implementation for Beam's stateful ParDo primitive.
StatefulParDoP.Supplier<OutputT>	Jet Processor supplier that will provide instances of StatefulParDoP.
UnboundedSourceP<T,CmT extends org.apache.beam.sdk.io.UnboundedSource.CheckpointMark>	Jet Processor implementation for reading from an unbounded Beam source.
ViewP	Jet Processor implementation for Beam's side input producing primitives.
WindowGroupP<K,V>	Jet Processor implementation for Beam's GroupByKeyOnly + GroupAlsoByWindow primitives.