Merge branch 'STORM-1030-V1' of https://github.com/harshach/incubator-storm into STORM-1030
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2eb80a0f Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2eb80a0f Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2eb80a0f Branch: refs/heads/master Commit: 2eb80a0fd783a1bec3192802bf8e01d6ff152d74 Parents: da7969e e5f0e91 Author: Jungtaek Lim <kabh...@gmail.com> Authored: Tue Mar 29 16:41:29 2016 +0900 Committer: Jungtaek Lim <kabh...@gmail.com> Committed: Tue Mar 29 16:41:29 2016 +0900 ---------------------------------------------------------------------- .../org/apache/storm/hive/bolt/HiveBolt.java | 147 ++++++++------ .../apache/storm/hive/common/HiveOptions.java | 8 +- .../org/apache/storm/hive/common/HiveUtils.java | 11 +- .../apache/storm/hive/common/HiveWriter.java | 127 ++++++++----- .../apache/storm/hive/trident/HiveState.java | 38 ++-- .../storm/hive/trident/HiveStateFactory.java | 1 + .../apache/storm/hive/trident/HiveUpdater.java | 1 + .../storm/hive/bolt/BucketTestHiveTopology.java | 190 +++++++++++++++++++ .../apache/storm/hive/bolt/HiveTopology.java | 6 +- .../apache/storm/hive/bolt/TestHiveBolt.java | 11 +- .../storm/hive/common/TestHiveWriter.java | 13 +- .../storm/hive/trident/TridentHiveTopology.java | 2 +- 12 files changed, 415 insertions(+), 140 deletions(-) ----------------------------------------------------------------------
