----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/20869/ -----------------------------------------------------------
Review request for samza. Repository: samza-hello-samza Description ------- a filereader system which reads specified file contents onto stream. 1. FileReaderSystemAdmin implements SystemAdmin and is similar to SinglePartitionWithoutOffsetsSystemAdmin except it updates offset. 2. FileReaderSystemFactory implements SystemFactory. It throws a Samza exception for getProducer because this system does not suppose to write to files. 3. FileReaderSystemConsumer gets file path from stream names, creates threads for each file and then read files line-by-line. It skips certain lines when its startingOffset is not zero, meaning it has checkpoint. Diffs ----- samza-wikipedia/src/main/java/samza/examples/file/system/FileReaderAdmin.java PRE-CREATION samza-wikipedia/src/main/java/samza/examples/file/system/FileReaderConsumer.java PRE-CREATION samza-wikipedia/src/main/java/samza/examples/file/system/FileReaderSystemFactory.java PRE-CREATION samza-wikipedia/src/main/java/samza/examples/filereader/system/FileReaderAdmin.java PRE-CREATION samza-wikipedia/src/main/java/samza/examples/filereader/system/FileReaderConsumer.java PRE-CREATION samza-wikipedia/src/main/java/samza/examples/filereader/system/FileReaderSystemFactory.java PRE-CREATION Diff: https://reviews.apache.org/r/20869/diff/ Testing ------- Thanks, Yan Fang
