Merge branch 'STORM-616' of https://github.com/Parth-Brahmbhatt/incubator-storm into STORM-616
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/10ea5e1f Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/10ea5e1f Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/10ea5e1f Branch: refs/heads/master Commit: 10ea5e1fc410d8d28510f324b73a8155740b04bb Parents: d733484 4fc8356 Author: Sriharsha Chintalapani <[email protected]> Authored: Mon Feb 23 13:28:53 2015 -0800 Committer: Sriharsha Chintalapani <[email protected]> Committed: Mon Feb 23 13:28:53 2015 -0800 ---------------------------------------------------------------------- external/storm-jdbc/LICENSE | 202 ++++++++++++++++ external/storm-jdbc/README.md | 240 +++++++++++++++++++ external/storm-jdbc/pom.xml | 125 ++++++++++ .../storm/jdbc/bolt/AbstractJdbcBolt.java | 57 +++++ .../apache/storm/jdbc/bolt/JdbcInsertBolt.java | 71 ++++++ .../apache/storm/jdbc/bolt/JdbcLookupBolt.java | 76 ++++++ .../org/apache/storm/jdbc/common/Column.java | 111 +++++++++ .../apache/storm/jdbc/common/JdbcClient.java | 228 ++++++++++++++++++ .../java/org/apache/storm/jdbc/common/Util.java | 74 ++++++ .../storm/jdbc/mapper/JdbcLookupMapper.java | 26 ++ .../apache/storm/jdbc/mapper/JdbcMapper.java | 33 +++ .../jdbc/mapper/SimpleJdbcLookupMapper.java | 46 ++++ .../storm/jdbc/mapper/SimpleJdbcMapper.java | 92 +++++++ .../storm/jdbc/trident/state/JdbcQuery.java | 40 ++++ .../storm/jdbc/trident/state/JdbcState.java | 145 +++++++++++ .../jdbc/trident/state/JdbcStateFactory.java | 40 ++++ .../storm/jdbc/trident/state/JdbcUpdater.java | 32 +++ .../storm/jdbc/common/JdbcClientTest.java | 88 +++++++ .../org/apache/storm/jdbc/spout/UserSpout.java | 90 +++++++ .../jdbc/topology/AbstractUserTopology.java | 106 ++++++++ .../jdbc/topology/UserPersistanceTopology.java | 48 ++++ .../UserPersistanceTridentTopology.java | 61 +++++ external/storm-jdbc/src/test/sql/test.sql | 1 + pom.xml | 1 + storm-dist/binary/src/main/assembly/binary.xml | 16 +- 25 files changed, 2047 insertions(+), 2 deletions(-) ----------------------------------------------------------------------
