org.apache.nemo.compiler.frontend.beam.source (Nemo Project 0.4 API)

Class Summary
Class	Description
BeamBoundedSourceVertex<O>	SourceVertex implementation for BoundedSource.
BeamUnboundedSourceVertex<O,M extends org.apache.beam.sdk.io.UnboundedSource.CheckpointMark>	SourceVertex implementation for UnboundedSource.

Package org.apache.nemo.compiler.frontend.beam.source