You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2018/07/30 18:45:17 UTC
[4/4] storm git commit: Merge branch 'STORM-3156' of
https://github.com/srdo/storm into STORM-3156
Merge branch 'STORM-3156' of https://github.com/srdo/storm into STORM-3156
STORM-3156: Remove the transactional topology API
This closes #2768
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/31624a2d
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/31624a2d
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/31624a2d
Branch: refs/heads/master
Commit: 31624a2d2f9ed2df0fd37ee871e45e321735d27c
Parents: c8896ef da0bc6a
Author: Robert Evans <ev...@yahoo-inc.com>
Authored: Mon Jul 30 13:24:31 2018 -0500
Committer: Robert Evans <ev...@yahoo-inc.com>
Committed: Mon Jul 30 13:24:31 2018 -0500
----------------------------------------------------------------------
docs/Structure-of-the-codebase.md | 33 +-
docs/Trident-tutorial.md | 2 +
docs/Tutorial.md | 4 +-
docs/index.md | 2 +-
docs/storm-sql.md | 2 +-
.../storm/starter/TransactionalGlobalCount.java | 165 -----
.../storm/starter/TransactionalWords.java | 234 ------
.../apache/storm/testing/BatchNumberList.java | 65 --
.../apache/storm/testing/BatchProcessWord.java | 34 -
.../org/apache/storm/testing/BatchRepeatA.java | 43 --
.../apache/storm/testing/CountingBatchBolt.java | 50 --
.../storm/testing/CountingCommitBolt.java | 52 --
.../storm/testing/KeyedCountingBatchBolt.java | 56 --
.../testing/KeyedCountingCommitterBolt.java | 19 -
.../storm/testing/KeyedSummingBatchBolt.java | 55 --
.../storm/testing/MemoryTransactionalSpout.java | 185 -----
.../testing/MemoryTransactionalSpoutMeta.java | 33 -
.../testing/OpaqueMemoryTransactionalSpout.java | 187 -----
...BaseOpaquePartitionedTransactionalSpout.java | 20 -
.../base/BasePartitionedTransactionalSpout.java | 19 -
.../topology/base/BaseTransactionalBolt.java | 19 -
.../topology/base/BaseTransactionalSpout.java | 19 -
.../apache/storm/transactional/ICommitter.java | 21 -
.../ICommitterTransactionalSpout.java | 26 -
.../transactional/ITransactionalSpout.java | 85 ---
.../storm/transactional/TransactionAttempt.java | 4 +
.../TransactionalSpoutBatchExecutor.java | 91 ---
.../TransactionalSpoutCoordinator.java | 209 ------
.../TransactionalTopologyBuilder.java | 562 ---------------
.../IOpaquePartitionedTransactionalSpout.java | 52 --
.../IPartitionedTransactionalSpout.java | 64 --
...uePartitionedTransactionalSpoutExecutor.java | 158 -----
.../PartitionedTransactionalSpoutExecutor.java | 138 ----
.../state/RotatingTransactionalState.java | 149 ----
.../state/TestTransactionalState.java | 38 -
.../transactional/state/TransactionalState.java | 185 -----
.../clj/org/apache/storm/transactional_test.clj | 706 -------------------
37 files changed, 26 insertions(+), 3760 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/31624a2d/docs/index.md
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/31624a2d/docs/storm-sql.md
----------------------------------------------------------------------