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

Class CreateStreamingSparkView.CreateSparkPCollectionView<ElemT,ViewT>

java.lang.Object
org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<List<ElemT>>,org.apache.beam.sdk.values.PCollection<List<ElemT>>>
org.apache.beam.runners.spark.translation.streaming.CreateStreamingSparkView.CreateSparkPCollectionView<ElemT,ViewT>
Type Parameters:
ElemT - The type of the elements of the input PCollection
ViewT - The type associated with the PCollectionView used as a side input
All Implemented Interfaces:
Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData
Enclosing class:
CreateStreamingSparkView<ElemT,ViewT>
public static class CreateStreamingSparkView.CreateSparkPCollectionView<ElemT,ViewT> extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<List<ElemT>>,org.apache.beam.sdk.values.PCollection<List<ElemT>>>
Creates a primitive PCollectionView.

For internal use only by runner implementors.

See Also:

  • Field Summary

    Fields inherited from class org.apache.beam.sdk.transforms.PTransform

    annotations, displayData, name, resourceHints

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.beam.sdk.values.PCollection<List<ElemT>>
    expand(org.apache.beam.sdk.values.PCollection<List<ElemT>> input)
     
    org.apache.beam.sdk.values.PCollectionView<ViewT>
    getView()
     
    static <ElemT, ViewT>
    CreateStreamingSparkView.CreateSparkPCollectionView<ElemT,ViewT>
    of(org.apache.beam.sdk.values.PCollectionView<ViewT> view)
     

    Methods inherited from class org.apache.beam.sdk.transforms.PTransform

    addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate

    Methods inherited from class java.lang.Object

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

  • Method Details

    • of

      public static <ElemT, ViewT> CreateStreamingSparkView.CreateSparkPCollectionView<ElemT,ViewT> of(org.apache.beam.sdk.values.PCollectionView<ViewT> view)

    • expand

      public org.apache.beam.sdk.values.PCollection<List<ElemT>> expand(org.apache.beam.sdk.values.PCollection<List<ElemT>> input)
      Specified by:
      expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<List<ElemT>>,org.apache.beam.sdk.values.PCollection<List<ElemT>>>

    • getView

      public org.apache.beam.sdk.values.PCollectionView<ViewT> getView()