You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/10/15 18:15:35 UTC
[22/50] git commit: Merge branch 'storm-hbase' of
github.com:ptgoetz/incubator-storm
Merge branch 'storm-hbase' of github.com:ptgoetz/incubator-storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9f712703
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9f712703
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9f712703
Branch: refs/heads/security
Commit: 9f712703e3c1017f79054a59230ce0a462504251
Parents: 0390891 4c515dd
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Oct 1 15:59:44 2014 -0700
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Oct 1 15:59:44 2014 -0700
----------------------------------------------------------------------
external/storm-hbase/LICENSE | 202 ++++++++++++++++
external/storm-hbase/README.md | 213 +++++++++++++++++
external/storm-hbase/pom.xml | 78 +++++++
.../storm/hbase/bolt/AbstractHBaseBolt.java | 69 ++++++
.../org/apache/storm/hbase/bolt/HBaseBolt.java | 77 ++++++
.../storm/hbase/bolt/HBaseLookupBolt.java | 83 +++++++
.../storm/hbase/bolt/mapper/HBaseMapper.java | 48 ++++
.../bolt/mapper/HBaseProjectionCriteria.java | 85 +++++++
.../hbase/bolt/mapper/HBaseValueMapper.java | 41 ++++
.../hbase/bolt/mapper/SimpleHBaseMapper.java | 90 +++++++
.../apache/storm/hbase/common/ColumnList.java | 202 ++++++++++++++++
.../apache/storm/hbase/common/HBaseClient.java | 135 +++++++++++
.../org/apache/storm/hbase/common/IColumn.java | 30 +++
.../org/apache/storm/hbase/common/ICounter.java | 29 +++
.../org/apache/storm/hbase/common/Utils.java | 69 ++++++
.../storm/hbase/security/HBaseSecurityUtil.java | 52 +++++
.../mapper/SimpleTridentHBaseMapper.java | 89 +++++++
.../trident/mapper/TridentHBaseMapper.java | 31 +++
.../hbase/trident/state/HBaseMapState.java | 233 +++++++++++++++++++
.../storm/hbase/trident/state/HBaseQuery.java | 40 ++++
.../storm/hbase/trident/state/HBaseState.java | 162 +++++++++++++
.../hbase/trident/state/HBaseStateFactory.java | 40 ++++
.../storm/hbase/trident/state/HBaseUpdater.java | 32 +++
.../storm/hbase/topology/LookupWordCount.java | 79 +++++++
.../hbase/topology/PersistentWordCount.java | 81 +++++++
.../storm/hbase/topology/TotalWordCounter.java | 70 ++++++
.../storm/hbase/topology/WordCountClient.java | 57 +++++
.../hbase/topology/WordCountValueMapper.java | 69 ++++++
.../storm/hbase/topology/WordCounter.java | 59 +++++
.../apache/storm/hbase/topology/WordSpout.java | 88 +++++++
.../storm/hbase/trident/PrintFunction.java | 40 ++++
.../storm/hbase/trident/WordCountTrident.java | 104 +++++++++
pom.xml | 1 +
storm-dist/binary/src/main/assembly/binary.xml | 14 ++
34 files changed, 2792 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/9f712703/pom.xml
----------------------------------------------------------------------