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 <[email protected]> Authored: Tue Aug 9 10:27:30 2016 +0530 Committer: Satish Duggana <[email protected]> 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(-) ----------------------------------------------------------------------
