You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by do...@apache.org on 2016/04/07 18:53:53 UTC
[2/3] storm git commit: Merge branch 'STORM-1494' of
https://github.com/dossett/storm into STORM-1464
Merge branch 'STORM-1494' of https://github.com/dossett/storm into STORM-1464
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1b6724c2
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1b6724c2
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1b6724c2
Branch: refs/heads/master
Commit: 1b6724c2ff4bc61b49c5d0d8956984bf4be68256
Parents: 4284b09 7554fe2
Author: Aaron Dossett <aa...@target.com>
Authored: Thu Apr 7 11:22:11 2016 -0500
Committer: Aaron Dossett <aa...@target.com>
Committed: Thu Apr 7 11:22:11 2016 -0500
----------------------------------------------------------------------
external/storm-hdfs/README.md | 29 ++-
.../storm/hdfs/bolt/AbstractHdfsBolt.java | 182 +++++++++++++------
.../storm/hdfs/bolt/AvroGenericRecordBolt.java | 75 +++-----
.../org/apache/storm/hdfs/bolt/HdfsBolt.java | 39 ++--
.../storm/hdfs/bolt/SequenceFileBolt.java | 35 ++--
.../hdfs/bolt/rotation/FileRotationPolicy.java | 5 +
.../bolt/rotation/FileSizeRotationPolicy.java | 8 +
.../hdfs/bolt/rotation/NoRotationPolicy.java | 5 +
.../hdfs/bolt/rotation/TimedRotationPolicy.java | 8 +
.../storm/hdfs/common/AbstractHDFSWriter.java | 68 +++++++
.../common/AvroGenericRecordHDFSWriter.java | 80 ++++++++
.../apache/storm/hdfs/common/HDFSWriter.java | 66 +++++++
.../storm/hdfs/common/NullPartitioner.java | 31 ++++
.../apache/storm/hdfs/common/Partitioner.java | 36 ++++
.../storm/hdfs/common/SequenceFileWriter.java | 59 ++++++
.../hdfs/bolt/AvroGenericRecordBoltTest.java | 105 ++++++++---
.../apache/storm/hdfs/bolt/TestHdfsBolt.java | 34 +++-
.../storm/hdfs/bolt/TestSequenceFileBolt.java | 4 +-
.../apache/storm/hdfs/bolt/TestWritersMap.java | 48 +++++
19 files changed, 730 insertions(+), 187 deletions(-)
----------------------------------------------------------------------