Class WindowFn.MergeContext

    • Constructor Summary

      Constructors 
      Constructor Description
      MergeContext()  
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      abstract void merge​(java.util.Collection<W> toBeMerged, W mergeResult)
      Signals to the framework that the windows in toBeMerged should be merged together to form mergeResult.
      abstract java.util.Collection<W> windows()
      Returns the current set of windows.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • MergeContext

        public MergeContext()
    • Method Detail

      • windows

        public abstract java.util.Collection<W> windows()
        Returns the current set of windows.
      • merge

        public abstract void merge​(java.util.Collection<W> toBeMerged,
                                   W mergeResult)
                            throws java.lang.Exception
        Signals to the framework that the windows in toBeMerged should be merged together to form mergeResult.

        toBeMerged should be a subset of windows() and disjoint from the toBeMerged set of previous calls to merge.

        mergeResult must either not be in windows() or be in toBeMerged.

        Throws:
        java.lang.IllegalArgumentException - if any elements of toBeMerged are not in windows(), or have already been merged
        java.lang.Exception