@Override
  public void close() {
    LOG.info("About to close file reader for " + systemStreamPartition);
    try {
      fileReader.close();
    } catch (IOException e) {
      throw new SamzaException(e);
    }
    LOG.info("File reader closed for " + systemStreamPartition);
  }
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