- All Implemented Interfaces:
- java.io.Serializable, TransformTranslator<org.apache.beam.runners.gearpump.translators.CreateStreamingGearpumpView.CreateGearpumpPCollectionView<ElemT,ViewT>>
public class CreateGearpumpPCollectionViewTranslator<ElemT,ViewT>
extends java.lang.Object
implements TransformTranslator<org.apache.beam.runners.gearpump.translators.CreateStreamingGearpumpView.CreateGearpumpPCollectionView<ElemT,ViewT>>
CreateGearpumpPCollectionView bridges input stream to down stream transforms.
- See Also:
- Serialized Form