@Override
  public DfType correctTypeOnFlush(DfType typeBeforeFlush) {
    if (typeBeforeFlush == CONSUMED) return typeBeforeFlush;
    return this;
  }
@Override
  public DfType correctTypeOnFlush(DfType typeBeforeFlush)