@Override
  public String toString() {
    return drainStates.toString();
  }
Checks if all streams (input SSPs) for the task has drained.
samza-core/src/main/java/org/apache/samza/operators/impl/DrainStates.java