public static String getCurSingleFileOffset(String offset) {
    String[] elements = offset.split(DELIMITER);
    if (elements.length < 2) {
      throw new SamzaException("Invalid offset for MultiFileHdfsReader: " + offset);
    }
    // Getting the remaining of the offset string in case the single file
    // offset uses the same delimiter.
    return offset.substring(elements[0].length() + 1);
  }
Get the offset within file from the offset string
@param offset offset string that contains both file index and offset within file
@return the single file offset part
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/MultiFileHdfsReader.java