Path	Lines of Code
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemAdmin.java	133
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemConsumer.java	180
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/PartitionDescriptorUtil.java	57
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsInputDescriptor.java	10
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsOutputDescriptor.java	10
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsSystemDescriptor.java	112
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/DirectoryPartitioner.java	135
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/FileSystemAdapter.java	23
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/HdfsFileSystemAdapter.java	33
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/AvroFileHdfsReader.java	143
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/HdfsReaderFactory.java	29
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/MultiFileHdfsReader.java	120
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/SingleFileHdfsReader.java	10
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsConfig.scala	83
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemFactory.scala	30
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemProducer.scala	73
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemProducerMetrics.scala	13
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/AvroDataFileHdfsWriter.scala	49
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/BinarySequenceFileHdfsWriter.scala	18
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/Bucketer.scala	16
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/HdfsWriter.scala	20
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/JobNameDateTimeBucketer.scala	30
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/SequenceFileHdfsWriter.scala	61
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/TextSequenceFileHdfsWriter.scala	18