@Override
  public boolean equals(Object o) {
    if (this == o) {
      return true;
    }
    if (o == null || getClass() != o.getClass()) {
      return false;
    }
    DrainNotification that = (DrainNotification) o;
    return Objects.equal(uuid, that.uuid)
        && Objects.equal(runId, that.runId)
        && Objects.equal(drainMode, that.drainMode);
  }
Creates a DrainNotification in {@link DrainMode#DEFAULT} mode.
samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java