class OffsetBasedSource extends BoundedSource<T> {

  @Override
  public String toString() {
    return "[" + startOffset + ", " + endOffset + ")";
  }

  public  OffsetBasedSource(long startOffset, long endOffset, long minBundleSize);

}