Merge branch 'STORM-1199' of github.com:roshannaik/storm into 1.x-branch
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2ac3f040 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2ac3f040 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2ac3f040 Branch: refs/heads/1.x-branch Commit: 2ac3f040733d033ad9a9108e885e04027f4eda48 Parents: 0bf5529 d17b3b9 Author: P. Taylor Goetz <[email protected]> Authored: Fri Jan 15 11:42:04 2016 -0500 Committer: P. Taylor Goetz <[email protected]> Committed: Fri Jan 15 11:42:04 2016 -0500 ---------------------------------------------------------------------- README.markdown | 1 + examples/storm-starter/pom.xml | 5 + .../jvm/storm/starter/HdfsSpoutTopology.java | 145 ++++ external/storm-hdfs/README.md | 139 +++- .../org/apache/storm/hdfs/common/HdfsUtils.java | 100 +++ .../storm/hdfs/common/ModifTimeComparator.java | 32 + .../storm/hdfs/spout/AbstractFileReader.java | 60 ++ .../org/apache/storm/hdfs/spout/Configs.java | 46 ++ .../org/apache/storm/hdfs/spout/DirLock.java | 133 ++++ .../org/apache/storm/hdfs/spout/FileLock.java | 333 +++++++++ .../org/apache/storm/hdfs/spout/FileOffset.java | 36 + .../org/apache/storm/hdfs/spout/FileReader.java | 44 ++ .../org/apache/storm/hdfs/spout/HdfsSpout.java | 741 +++++++++++++++++++ .../apache/storm/hdfs/spout/ParseException.java | 26 + .../storm/hdfs/spout/ProgressTracker.java | 70 ++ .../storm/hdfs/spout/SequenceFileReader.java | 213 ++++++ .../apache/storm/hdfs/spout/TextFileReader.java | 192 +++++ .../apache/storm/hdfs/spout/TestDirLock.java | 188 +++++ .../apache/storm/hdfs/spout/TestFileLock.java | 396 ++++++++++ .../storm/hdfs/spout/TestHdfsSemantics.java | 204 +++++ .../apache/storm/hdfs/spout/TestHdfsSpout.java | 720 ++++++++++++++++++ .../storm/hdfs/spout/TestProgressTracker.java | 124 ++++ .../src/test/resources/log4j.properties | 26 + pom.xml | 2 +- 24 files changed, 3966 insertions(+), 10 deletions(-) ----------------------------------------------------------------------
