Package org.apache.beam.runners.spark.translation.streaming

Class CreateStreamingSparkView.Factory<ElemT,​ViewT>

  • All Implemented Interfaces:
    org.apache.beam.sdk.runners.PTransformOverrideFactory<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>>>
    Enclosing class:
    CreateStreamingSparkView<ElemT,​ViewT>
    public static class CreateStreamingSparkView.Factory<ElemT,​ViewT>
extends java.lang.Object
implements org.apache.beam.sdk.runners.PTransformOverrideFactory<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>>>

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.beam.sdk.runners.PTransformOverrideFactory

        org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<InputT extends org.apache.beam.sdk.values.PInput,​OutputT extends org.apache.beam.sdk.values.POutput>, org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>> getReplacementTransform​(org.apache.beam.sdk.runners.AppliedPTransform<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>>> transform)  
      java.util.Map<org.apache.beam.sdk.values.PCollection<?>,​org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput> mapOutputs​(java.util.Map<org.apache.beam.sdk.values.TupleTag<?>,​org.apache.beam.sdk.values.PCollection<?>> outputs, org.apache.beam.sdk.values.PCollection<ElemT> newOutput)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • getReplacementTransform

        public org.apache.beam.sdk.runners.PTransformOverrideFactory.PTransformReplacement<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>> getReplacementTransform​(org.apache.beam.sdk.runners.AppliedPTransform<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>>> transform)
        Specified by:
        getReplacementTransform in interface org.apache.beam.sdk.runners.PTransformOverrideFactory<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>>>

      • mapOutputs

        public java.util.Map<org.apache.beam.sdk.values.PCollection<?>,​org.apache.beam.sdk.runners.PTransformOverrideFactory.ReplacementOutput> mapOutputs​(java.util.Map<org.apache.beam.sdk.values.TupleTag<?>,​org.apache.beam.sdk.values.PCollection<?>> outputs,
                                                                                                                                                         org.apache.beam.sdk.values.PCollection<ElemT> newOutput)
        Specified by:
        mapOutputs in interface org.apache.beam.sdk.runners.PTransformOverrideFactory<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<ElemT>,​org.apache.beam.sdk.values.PCollection<ElemT>>>