You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pa...@apache.org on 2016/01/14 21:56:10 UTC
[19/20] storm git commit: Merge branch 'STORM-1199' of
https://github.com/roshannaik/storm into STORM-1199
Merge branch 'STORM-1199' of https://github.com/roshannaik/storm into STORM-1199
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/91cbb38b
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/91cbb38b
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/91cbb38b
Branch: refs/heads/master
Commit: 91cbb38bfb9a17e4a38fc70aff96f5703b7bd1b7
Parents: 6fcebe6 d17b3b9
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Thu Jan 14 12:41:23 2016 -0800
Committer: Parth Brahmbhatt <br...@gmail.com>
Committed: Thu Jan 14 12:41:23 2016 -0800
----------------------------------------------------------------------
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 +-
23 files changed, 3965 insertions(+), 10 deletions(-)
----------------------------------------------------------------------