You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2016/01/20 23:15:09 UTC
[07/46] storm git commit: Merge branch 'STORM-1199' of
github.com:roshannaik/storm into 1.x-branch
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/master
Commit: 2ac3f040733d033ad9a9108e885e04027f4eda48
Parents: 0bf5529 d17b3b9
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Fri Jan 15 11:42:04 2016 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
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(-)
----------------------------------------------------------------------