Interface ScriptOperators.Accumulator.AccumulatorMergeBuilder

All Known Subinterfaces:
ScriptOperators.Accumulator.AccumulatorAccumulateArgsBuilder
Enclosing class:
ScriptOperators.Accumulator

public static interface ScriptOperators.Accumulator.AccumulatorMergeBuilder
  • Method Details

    • merge

      Set the merge function used to merge two internal states.
      This might be required because the operation is run on a sharded cluster or when the operator exceeds its memory limit.
      function(state1, state2) { ... return newState }
      Parameters:
      function - must not be null.
      Returns:
      this.