Merge branch 'STORM-1714-1.x' into 1.x-branch
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0ba4bb51 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0ba4bb51 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0ba4bb51 Branch: refs/heads/1.x-branch Commit: 0ba4bb5100efff705f3b62b78ad476c2591d7eb2 Parents: a7370a6 95e7afc Author: Jungtaek Lim <[email protected]> Authored: Wed Apr 20 17:23:12 2016 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Wed Apr 20 17:23:12 2016 +0900 ---------------------------------------------------------------------- .../topology/BaseStatefulBoltExecutor.java | 209 +++++++++++++++++++ .../topology/CheckpointTupleForwarder.java | 159 +------------- .../apache/storm/topology/IStatefulBolt.java | 19 +- .../storm/topology/StatefulBoltExecutor.java | 22 +- .../apache/storm/topology/TopologyBuilder.java | 48 +++++ 5 files changed, 301 insertions(+), 156 deletions(-) ----------------------------------------------------------------------
