See: Description
| 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 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. |