@Override
  public WatermarkFunction getWatermarkFn() {
    return null;
  }
The spec for an operator that combines messages from all input streams into a single output stream.

@param <M> the type of messages in all input streams
samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java