Package cz.o2.proxima.beam.core

Class PCollectionTools

  • public class PCollectionTools
extends java.lang.Object
    Various tools related to manipulation with PCollections.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static org.apache.beam.sdk.values.PCollection<StreamElement> reduceAsSnapshot​(java.lang.String name, org.apache.beam.sdk.values.PCollection<StreamElement> input)
      Reduce given PCollection from updates to snapshot.

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • reduceAsSnapshot

        public static org.apache.beam.sdk.values.PCollection<StreamElement> reduceAsSnapshot​(@Nullable
                                                                                     java.lang.String name,
                                                                                     org.apache.beam.sdk.values.PCollection<StreamElement> input)
        Reduce given PCollection from updates to snapshot.
        Parameters:
        name - name of the operation
        input - the other PCollection containing updates
        Returns:
        snapshot