package wedo.dataflux.windowing.trigger;

import org.apache.flink.api.common.functions.ReduceFunction;

/**
 * Created by nrgoncalves
 */
public class SignalReduceFunction implements ReduceFunction<Long> {

  private static final long serialVersionUID = 1L;

  // --------------------------------------------------------------------------------------------

  /**
   * cannot instantiate
   */
  private SignalReduceFunction() {

  }

  // --------------------------------------------------------------------------------------------

  public static SignalReduceFunction create() {
    return new SignalReduceFunction();
  }

  // --------------------------------------------------------------------------------------------

  @Override
  public Long reduce(Long signal1, Long signal2) throws Exception {
    return Math.max(signal1, signal2);
  }
}