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(-)
----------------------------------------------------------------------