storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [3/3] storm git commit: Merge branch 'STORM-2974' of https://github.com/srdo/storm into STORM-2974-merge
Date Fri, 13 Jul 2018 12:26:43 GMT
Merge branch 'STORM-2974' of https://github.com/srdo/storm into STORM-2974-merge


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e21110d3
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e21110d3
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e21110d3

Branch: refs/heads/master
Commit: e21110d338fe8ca71b904682be35642a00de9e78
Parents: efb2e9a ba52607
Author: Jungtaek Lim <kabhwan@gmail.com>
Authored: Fri Jul 13 21:25:41 2018 +0900
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Fri Jul 13 21:25:41 2018 +0900

----------------------------------------------------------------------
 bin/storm.py                                    |   4 +-
 docs/Command-line-client.md                     |   2 +-
 docs/Transactional-topologies.md                |   6 +-
 docs/Trident-state.md                           |   4 +-
 docs/flux.md                                    |   2 +-
 .../TridentKafkaClientTopologyNamedTopics.java  |  16 +-
 .../kafka/spout/EmptyKafkaTupleListener.java    |   1 -
 .../apache/storm/kafka/spout/KafkaSpout.java    |  90 ++++----
 .../storm/kafka/spout/KafkaSpoutConfig.java     |   1 -
 .../storm/kafka/spout/KafkaTupleListener.java   |   1 -
 .../kafka/spout/internal/ConsumerFactory.java   |  28 +++
 .../spout/internal/ConsumerFactoryDefault.java  |  29 +++
 .../spout/internal/KafkaConsumerFactory.java    |  28 ---
 .../internal/KafkaConsumerFactoryDefault.java   |  29 ---
 .../kafka/spout/internal/OffsetManager.java     |   2 -
 .../kafka/spout/metrics/KafkaOffsetMetric.java  |  15 +-
 .../spout/subscription/NamedTopicFilter.java    |   4 +-
 .../spout/subscription/PatternTopicFilter.java  |   7 +-
 .../kafka/spout/subscription/TopicAssigner.java |   5 +-
 .../kafka/spout/subscription/TopicFilter.java   |   4 +-
 .../trident/KafkaTridentOpaqueSpoutEmitter.java |  68 ++++++
 .../trident/KafkaTridentSpoutBatchMetadata.java |  23 +-
 .../trident/KafkaTridentSpoutCoordinator.java   |  97 ++++++++
 .../spout/trident/KafkaTridentSpoutEmitter.java | 219 ++++++++++++-------
 .../spout/trident/KafkaTridentSpoutOpaque.java  |  18 +-
 .../KafkaTridentSpoutOpaqueCoordinator.java     |  94 --------
 .../trident/KafkaTridentSpoutTransactional.java |  65 ++++++
 .../KafkaTridentTransactionalSpoutEmitter.java  |  68 ++++++
 .../trident/internal/OutputFieldsExtractor.java |  41 ++++
 .../kafka/spout/KafkaSpoutAbstractTest.java     |  11 +-
 .../storm/kafka/spout/KafkaSpoutEmitTest.java   |  10 +-
 .../KafkaSpoutLogCompactionSupportTest.java     |  39 ++--
 .../kafka/spout/KafkaSpoutReactivationTest.java |  12 +-
 .../kafka/spout/KafkaSpoutRebalanceTest.java    |  32 +--
 .../kafka/spout/KafkaSpoutRetryLimitTest.java   |  19 +-
 .../kafka/spout/MaxUncommittedOffsetTest.java   |   7 +-
 .../spout/SingleTopicKafkaUnitSetupHelper.java  |   4 +-
 .../SpoutWithMockedConsumerSetupHelper.java     |   4 +-
 .../KafkaTridentSpoutBatchMetadataTest.java     |  10 +-
 .../trident/KafkaTridentSpoutEmitterTest.java   | 147 +++++++++----
 .../KafkaTridentSpoutOpaqueCoordinatorTest.java |   9 +-
 41 files changed, 833 insertions(+), 442 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/e21110d3/bin/storm.py
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/storm/blob/e21110d3/docs/Command-line-client.md
----------------------------------------------------------------------


Mime
View raw message