Package org.apache.flink.table.runtime.operators.window

Interface MergeCallback<W,​R>

  • Type Parameters:
    W - The type Window for windows or the type Long for slices that this callback used to merge.
    R - The result type like Collection or Iterable to specify which slices or windows should be merged.
    All Known Implementing Classes:
    SliceSharedSyncStateWindowAggProcessor
    public interface MergeCallback<W,​R>
    Callback to be used in when merging slices or windows for specifying which slices or windows should be merged.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void merge​(W mergeResult, R toBeMerged)
      Specifies that states of the given windows or slices should be merged into the result window or slice.

    • Method Detail

      • merge

        void merge​(@Nullable
           W mergeResult,
           R toBeMerged)
    throws Exception
        Specifies that states of the given windows or slices should be merged into the result window or slice.
        Parameters:
        mergeResult - The resulting merged window or slice, null if it represents a non-state namespace.
        toBeMerged - Windows or slices that should be merged into one window or slice.
        Throws:
        Exception