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

package org.apache.beam.runners.jet.processors
Individual DAG node processors used by the Beam runner for Hazelcast Jet.
  • Classes
    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.