----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/20869/ -----------------------------------------------------------
(Updated April 30, 2014, 12:42 a.m.) Review request for samza. Changes ------- Accidently uploaded the code with old class name. Update to the new name. 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 (updated) ----- samza-wikipedia/src/main/java/samza/examples/filereader/system/FileReaderSystemAdmin.java PRE-CREATION samza-wikipedia/src/main/java/samza/examples/filereader/system/FileReaderSystemConsumer.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
