public static int offsetComparator(String offset1, String offset2) {
    AvroFileCheckpoint cp1 = new AvroFileCheckpoint(offset1);
    AvroFileCheckpoint cp2 = new AvroFileCheckpoint(offset2);
    return cp1.compareTo(cp2);
  }
An implementation of the HdfsReader that reads and processes avro format
files.
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/AvroFileHdfsReader.java