storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [7/7] storm git commit: Merge branch 'STORM-2953-new' of https://github.com/srdo/storm into STORM-2953-test
Date Thu, 19 Jul 2018 03:35:03 GMT
Merge branch 'STORM-2953-new' of https://github.com/srdo/storm into STORM-2953-test


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

Branch: refs/heads/master
Commit: a7e817bcd1424d300ab5bad06c5d9f4729d9f347
Parents: 3883bf7 e58ac3e
Author: Jungtaek Lim <kabhwan@gmail.com>
Authored: Thu Jul 19 12:29:34 2018 +0900
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Thu Jul 19 12:29:34 2018 +0900

----------------------------------------------------------------------
 docs/index.md                                   |   2 +-
 docs/storm-kafka-client.md                      |   7 +-
 docs/storm-kafka.md                             | 399 ------------------
 examples/storm-kafka-examples/pom.xml           | 110 -----
 .../kafka/trident/KafkaProducerTopology.java    |  75 ----
 .../trident/TridentKafkaConsumerTopology.java   |  42 --
 .../trident/TridentKafkaRandomStrings.java      |  82 ----
 .../kafka/trident/TridentKafkaTopology.java     |  83 ----
 external/storm-kafka-monitor/pom.xml            |   5 -
 .../storm/kafka/monitor/KafkaOffsetLagUtil.java | 298 +-------------
 .../kafka/monitor/OldKafkaSpoutOffsetQuery.java | 127 ------
 external/storm-kafka/README.md                  | 382 -----------------
 external/storm-kafka/pom.xml                    | 125 ------
 .../src/jvm/org/apache/storm/kafka/Broker.java  |  79 ----
 .../jvm/org/apache/storm/kafka/BrokerHosts.java |  20 -
 .../storm/kafka/ByteBufferSerializer.java       |  41 --
 .../storm/kafka/DynamicBrokersReader.java       | 208 ----------
 .../kafka/DynamicPartitionConnections.java      |  91 -----
 .../ExponentialBackoffMsgRetryManager.java      | 201 ---------
 .../storm/kafka/FailedFetchException.java       |  24 --
 .../storm/kafka/FailedMsgRetryManager.java      |  77 ----
 .../org/apache/storm/kafka/IntSerializer.java   |  42 --
 .../jvm/org/apache/storm/kafka/KafkaConfig.java |  49 ---
 .../jvm/org/apache/storm/kafka/KafkaError.java  |  38 --
 .../jvm/org/apache/storm/kafka/KafkaSpout.java  | 255 ------------
 .../jvm/org/apache/storm/kafka/KafkaUtils.java  | 288 -------------
 .../org/apache/storm/kafka/KeyValueScheme.java  |  21 -
 .../kafka/KeyValueSchemeAsMultiScheme.java      |  35 --
 .../storm/kafka/MessageMetadataScheme.java      |  21 -
 .../MessageMetadataSchemeAsMultiScheme.java     |  35 --
 .../jvm/org/apache/storm/kafka/Partition.java   |  85 ----
 .../storm/kafka/PartitionCoordinator.java       |  23 --
 .../apache/storm/kafka/PartitionManager.java    | 405 -------------------
 .../jvm/org/apache/storm/kafka/SpoutConfig.java |  58 ---
 .../apache/storm/kafka/StaticCoordinator.java   |  50 ---
 .../jvm/org/apache/storm/kafka/StaticHosts.java |  33 --
 .../storm/kafka/StaticPartitionConnections.java |  46 ---
 .../storm/kafka/StringKeyValueScheme.java       |  32 --
 .../kafka/StringMessageAndMetadataScheme.java   |  36 --
 .../storm/kafka/StringMultiSchemeWithTopic.java |  41 --
 .../org/apache/storm/kafka/StringScheme.java    |  44 --
 .../kafka/TopicOffsetOutOfRangeException.java   |  26 --
 .../org/apache/storm/kafka/ZkCoordinator.java   | 127 ------
 .../src/jvm/org/apache/storm/kafka/ZkHosts.java |  31 --
 .../src/jvm/org/apache/storm/kafka/ZkState.java | 112 -----
 .../org/apache/storm/kafka/bolt/KafkaBolt.java  | 172 --------
 .../FieldNameBasedTupleToKafkaMapper.java       |  43 --
 .../kafka/bolt/mapper/TupleToKafkaMapper.java   |  27 --
 .../bolt/selector/DefaultTopicSelector.java     |  29 --
 .../bolt/selector/FieldIndexTopicSelector.java  |  43 --
 .../bolt/selector/FieldNameTopicSelector.java   |  44 --
 .../kafka/bolt/selector/KafkaTopicSelector.java |  20 -
 .../apache/storm/kafka/trident/Coordinator.java |  46 ---
 .../storm/kafka/trident/DefaultCoordinator.java |  26 --
 .../trident/GlobalPartitionInformation.java     | 113 ------
 .../storm/kafka/trident/IBatchCoordinator.java  |  21 -
 .../storm/kafka/trident/IBrokerReader.java      |  24 --
 .../apache/storm/kafka/trident/MaxMetric.java   |  35 --
 .../kafka/trident/OpaqueTridentKafkaSpout.java  |  62 ---
 .../storm/kafka/trident/StaticBrokerReader.java |  44 --
 .../trident/TransactionalTridentKafkaSpout.java |  50 ---
 .../storm/kafka/trident/TridentKafkaConfig.java |  32 --
 .../kafka/trident/TridentKafkaEmitter.java      | 306 --------------
 .../storm/kafka/trident/TridentKafkaState.java  | 110 -----
 .../kafka/trident/TridentKafkaStateFactory.java |  57 ---
 .../kafka/trident/TridentKafkaUpdater.java      |  25 --
 .../storm/kafka/trident/ZkBrokerReader.java     |  79 ----
 .../FieldNameBasedTupleToKafkaMapper.java       |  36 --
 .../mapper/TridentTupleToKafkaMapper.java       |  22 -
 .../trident/selector/DefaultTopicSelector.java  |  29 --
 .../trident/selector/KafkaTopicSelector.java    |  20 -
 .../storm/kafka/DynamicBrokersReaderTest.java   | 245 -----------
 .../ExponentialBackoffMsgRetryManagerTest.java  | 279 -------------
 .../org/apache/storm/kafka/KafkaErrorTest.java  |  51 ---
 .../org/apache/storm/kafka/KafkaTestBroker.java | 177 --------
 .../org/apache/storm/kafka/KafkaUtilsTest.java  | 294 --------------
 .../storm/kafka/PartitionManagerTest.java       | 241 -----------
 .../storm/kafka/StringKeyValueSchemeTest.java   |  56 ---
 .../apache/storm/kafka/TestStringScheme.java    |  40 --
 .../test/org/apache/storm/kafka/TestUtils.java  |  97 -----
 .../apache/storm/kafka/TridentKafkaTest.java    |  75 ----
 .../apache/storm/kafka/ZkCoordinatorTest.java   | 191 ---------
 .../apache/storm/kafka/bolt/KafkaBoltTest.java  | 355 ----------------
 flux/flux-core/pom.xml                          |   5 +
 flux/flux-examples/pom.xml                      |   4 +
 flux/pom.xml                                    |   5 -
 pom.xml                                         |  31 +-
 .../apache/storm/utils/TopologySpoutLag.java    |  62 +--
 .../final-package/src/main/assembly/binary.xml  |   7 -
 89 files changed, 30 insertions(+), 8111 deletions(-)
----------------------------------------------------------------------



Mime
View raw message