Class GroupNonMergingWindowsFunctions

java.lang.Object
org.apache.beam.runners.spark.translation.GroupNonMergingWindowsFunctions

public class GroupNonMergingWindowsFunctions extends Object
Functions for GroupByKey with Non-Merging windows translations to Spark.
  • Constructor Details

    • GroupNonMergingWindowsFunctions

      public GroupNonMergingWindowsFunctions()