You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/02/25 19:53:00 UTC
[12/13] storm git commit: Merge branch 'STORM-539-V2' of
https://github.com/harshach/incubator-storm into STORM-539
Merge branch 'STORM-539-V2' of https://github.com/harshach/incubator-storm into STORM-539
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/59eb7f95
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/59eb7f95
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/59eb7f95
Branch: refs/heads/master
Commit: 59eb7f95a243cf23b7cbbbec843f7bdb7fac37f8
Parents: 0a3a0aa e62c163
Author: Sriharsha Chintalapani <ha...@hortonworks.com>
Authored: Wed Feb 25 08:16:11 2015 -0800
Committer: Sriharsha Chintalapani <ha...@hortonworks.com>
Committed: Wed Feb 25 08:16:11 2015 -0800
----------------------------------------------------------------------
.gitignore | 4 +-
external/storm-hive/README.md | 113 +++++
external/storm-hive/pom.xml | 143 +++++++
.../org/apache/storm/hive/bolt/HiveBolt.java | 289 +++++++++++++
.../bolt/mapper/DelimitedRecordHiveMapper.java | 143 +++++++
.../storm/hive/bolt/mapper/HiveMapper.java | 81 ++++
.../hive/bolt/mapper/JsonRecordHiveMapper.java | 132 ++++++
.../apache/storm/hive/common/HiveOptions.java | 146 +++++++
.../org/apache/storm/hive/common/HiveUtils.java | 76 ++++
.../apache/storm/hive/common/HiveWriter.java | 420 +++++++++++++++++++
.../apache/storm/hive/trident/HiveState.java | 306 ++++++++++++++
.../storm/hive/trident/HiveStateFactory.java | 31 ++
.../apache/storm/hive/trident/HiveUpdater.java | 14 +
.../apache/storm/hive/bolt/HiveSetupUtil.java | 220 ++++++++++
.../apache/storm/hive/bolt/HiveTopology.java | 150 +++++++
.../hive/bolt/HiveTopologyPartitioned.java | 153 +++++++
.../apache/storm/hive/bolt/TestHiveBolt.java | 330 +++++++++++++++
.../storm/hive/common/TestHiveWriter.java | 193 +++++++++
.../storm/hive/trident/TridentHiveTopology.java | 190 +++++++++
pom.xml | 4 +-
storm-dist/binary/src/main/assembly/binary.xml | 14 +
21 files changed, 3150 insertions(+), 2 deletions(-)
----------------------------------------------------------------------