You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sa...@apache.org on 2016/08/09 05:16:57 UTC

[2/3] storm git commit: Merge branch 'storm-druid' of https://github.com/omkreddy/storm into STORM-1979

Merge branch 'storm-druid' of https://github.com/omkreddy/storm into STORM-1979


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/52b67b4a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/52b67b4a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/52b67b4a

Branch: refs/heads/master
Commit: 52b67b4ae677b17e0d255fd103d2d24cd58ff2c0
Parents: 28563ec 422e053
Author: Satish Duggana <sd...@hortonworks.com>
Authored: Tue Aug 9 10:27:30 2016 +0530
Committer: Satish Duggana <sd...@hortonworks.com>
Committed: Tue Aug 9 10:27:30 2016 +0530

----------------------------------------------------------------------
 external/storm-druid/README.md                  | 143 +++++++++++++++++++
 external/storm-druid/pom.xml                    |  83 +++++++++++
 .../apache/storm/druid/bolt/DruidBeamBolt.java  | 110 ++++++++++++++
 .../storm/druid/bolt/DruidBeamFactory.java      |  29 ++++
 .../apache/storm/druid/bolt/DruidConfig.java    | 104 ++++++++++++++
 .../druid/bolt/ITupleDruidEventMapper.java      |  38 +++++
 .../storm/druid/bolt/TupleDruidEventMapper.java |  44 ++++++
 .../storm/druid/trident/DruidBeamState.java     |  96 +++++++++++++
 .../druid/trident/DruidBeamStateFactory.java    |  42 ++++++
 .../druid/trident/DruidBeamStateUpdater.java    |  48 +++++++
 .../storm/druid/SampleDruidBeamFactoryImpl.java | 122 ++++++++++++++++
 .../storm/druid/SampleDruidBoltTopology.java    |  95 ++++++++++++
 .../druid/SampleDruidBoltTridentTopology.java   |  91 ++++++++++++
 .../apache/storm/druid/SimpleBatchSpout.java    |  95 ++++++++++++
 .../org/apache/storm/druid/SimpleSpout.java     |  68 +++++++++
 pom.xml                                         |   1 +
 storm-dist/binary/src/main/assembly/binary.xml  |  15 +-
 17 files changed, 1223 insertions(+), 1 deletion(-)
----------------------------------------------------------------------