This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
from c9e181c83 STORM-3990 - Hadoop 2.10.2 (#3589)
add e73009ba4 STORM-3988 - Remove "storm-cassandra"
add 7f97a03aa STORM-3988 - Remove "storm-eventhubs"
add 7adbe83b3 STORM-3988 - Remove "storm-hbase"
add 78b799cb2 STORM-3988 - Remove "storm-kinesis"
add ee7d71c5e STORM-3988 - Remove "storm-mongodb"
add 8a2070dfb STORM-3988 - Remove "storm-mqtt"
add 50bb8c49e STORM-3988 - Remove "storm-opentsdb"
add 6c09b6e26 STORM-3988 - Remove "storm-pmml"
add e9db2b848 STORM-3988 - Remove "storm-pulsar"
add e655c6d88 STORM-3988 - Remove "storm-rocketmq"
add 80a29c925 STORM-3988 - Remove "storm-solr"
add 4dd83d7b8 STORM-3988 - Remove "storm-sql-mongodb"
add 782b0d8f5 STORM-3988 - Fix licenses after module removal
add 88c7d8985 STORM-3988 - Remove content from /docs
add 0da46cb58 Merge remote-tracking branch 'origin/master' into STORM-3988
add 4c82ee948 Merge remote-tracking branch 'origin/master' into STORM-3988
add e1efb4a3f Merge remote-tracking branch 'origin/master' into STORM-3988
add d2e670a66 Fix license
new 51480142b Merge pull request #3588 from apache/STORM-3988
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
DEPENDENCY-LICENSES | 117 -----
docs/storm-cassandra.md | 235 ----------
docs/storm-eventhubs.md | 40 --
docs/storm-hbase.md | 290 ------------
docs/storm-hive.md | 111 -----
docs/storm-kinesis.md | 145 ------
docs/storm-mongodb.md | 303 -------------
docs/storm-mqtt.md | 379 ----------------
docs/storm-opentsdb.md | 56 ---
docs/storm-pmml.md | 42 --
docs/storm-rocketmq.md | 98 -----
docs/storm-solr.md | 190 --------
examples/storm-hbase-examples/README.md | 62 ---
examples/storm-hbase-examples/pom.xml | 96 ----
.../storm/hbase/topology/LookupWordCount.java | 68 ---
.../storm/hbase/topology/PersistentWordCount.java | 79 ----
.../storm/hbase/topology/TotalWordCounter.java | 68 ---
.../storm/hbase/topology/WordCountClient.java | 54 ---
.../storm/hbase/topology/WordCountValueMapper.java | 62 ---
.../apache/storm/hbase/topology/WordCounter.java | 56 ---
.../org/apache/storm/hbase/topology/WordSpout.java | 87 ----
.../apache/storm/hbase/trident/PrintFunction.java | 34 --
.../storm/hbase/trident/WordCountTrident.java | 94 ----
examples/storm-mongodb-examples/pom.xml | 96 ----
.../storm/mongodb/topology/InsertWordCount.java | 72 ---
.../storm/mongodb/topology/LookupWordCount.java | 76 ----
.../storm/mongodb/topology/TotalWordCounter.java | 74 ----
.../storm/mongodb/topology/UpdateWordCount.java | 83 ----
.../apache/storm/mongodb/topology/WordCounter.java | 71 ---
.../apache/storm/mongodb/topology/WordSpout.java | 94 ----
.../storm/mongodb/trident/PrintFunction.java | 41 --
.../storm/mongodb/trident/WordCountTrident.java | 87 ----
.../storm/mongodb/trident/WordCountTridentMap.java | 89 ----
examples/storm-mqtt-examples/pom.xml | 145 ------
.../storm-mqtt-examples/src/main/flux/sample.yaml | 62 ---
.../src/main/flux/ssl-sample.yaml | 78 ----
.../storm/mqtt/examples/CustomMessageMapper.java | 79 ----
.../storm/mqtt/examples/MqttBrokerPublisher.java | 137 ------
.../apache/storm/mqtt/examples/package-info.java | 20 -
.../src/main/resources/log4j2.xml | 32 --
examples/storm-opentsdb-examples/pom.xml | 96 ----
.../apache/storm/opentsdb/MetricGenBatchSpout.java | 96 ----
.../org/apache/storm/opentsdb/MetricGenSpout.java | 74 ----
.../storm/opentsdb/SampleOpenTsdbBoltTopology.java | 61 ---
.../opentsdb/SampleOpenTsdbTridentTopology.java | 77 ----
examples/storm-pmml-examples/pom.xml | 96 ----
.../apache/storm/pmml/JpmmlRunnerTestTopology.java | 196 ---------
.../apache/storm/pmml/RawInputFromCSVSpout.java | 133 ------
.../src/main/resources/Audit.50.csv | 51 ---
...KNIME_PMML_4.1_Examples_single_audit_logreg.xml | 259 -----------
.../src/main/resources/README.md | 6 -
examples/storm-rocketmq-examples/pom.xml | 96 ----
.../storm/rocketmq/topology/WordCountTopology.java | 89 ----
.../storm/rocketmq/topology/WordCounter.java | 68 ---
.../storm/rocketmq/trident/WordCountTrident.java | 89 ----
examples/storm-solr-examples/pom.xml | 125 ------
.../apache/storm/solr/spout/SolrFieldsSpout.java | 77 ----
.../org/apache/storm/solr/spout/SolrJsonSpout.java | 117 -----
.../storm/solr/topology/SolrFieldsTopology.java | 61 ---
.../storm/solr/topology/SolrJsonTopology.java | 49 ---
.../apache/storm/solr/topology/SolrTopology.java | 71 ---
.../solr/trident/SolrFieldsTridentTopology.java | 48 --
.../solr/trident/SolrJsonTridentTopology.java | 46 --
.../java/org/apache/storm/solr/util/TestUtil.java | 30 --
external/storm-cassandra/README.md | 390 -----------------
external/storm-cassandra/pom.xml | 195 ---------
.../cassandra/AbstractExecutionResultHandler.java | 55 ---
.../cassandra/BaseExecutionResultHandler.java | 89 ----
.../apache/storm/cassandra/CassandraContext.java | 84 ----
.../storm/cassandra/DynamicStatementBuilder.java | 153 -------
.../storm/cassandra/ExecutionResultHandler.java | 94 ----
.../storm/cassandra/Murmur3StreamGrouping.java | 121 -----
.../storm/cassandra/bolt/BaseCassandraBolt.java | 205 ---------
.../cassandra/bolt/BatchCassandraWriterBolt.java | 196 ---------
.../storm/cassandra/bolt/CassandraWriterBolt.java | 59 ---
.../storm/cassandra/bolt/GroupingBatchBuilder.java | 57 ---
.../cassandra/bolt/PairBatchStatementTuples.java | 45 --
.../storm/cassandra/bolt/PairStatementTuple.java | 42 --
.../storm/cassandra/client/CassandraConf.java | 320 --------------
.../storm/cassandra/client/ClusterFactory.java | 73 ----
.../storm/cassandra/client/SimpleClient.java | 36 --
.../cassandra/client/SimpleClientProvider.java | 29 --
.../storm/cassandra/client/impl/DefaultClient.java | 119 -----
.../storm/cassandra/context/BaseBeanFactory.java | 64 ---
.../storm/cassandra/context/BeanFactory.java | 40 --
.../apache/storm/cassandra/context/WorkerCtx.java | 85 ----
.../storm/cassandra/executor/AsyncExecutor.java | 307 -------------
.../cassandra/executor/AsyncExecutorProvider.java | 34 --
.../cassandra/executor/AsyncResultHandler.java | 57 ---
.../cassandra/executor/AsyncResultSetHandler.java | 51 ---
.../executor/ExecutionResultCollector.java | 97 ----
.../executor/impl/BatchAsyncResultHandler.java | 67 ---
.../executor/impl/SingleAsyncResultHandler.java | 66 ---
.../query/AyncCQLResultSetValuesMapper.java | 30 --
.../query/BaseCQLStatementTupleMapper.java | 44 --
.../cassandra/query/CQLResultSetValuesMapper.java | 27 --
.../storm/cassandra/query/CQLStatementBuilder.java | 25 --
.../cassandra/query/CQLStatementTupleMapper.java | 56 ---
.../org/apache/storm/cassandra/query/Column.java | 76 ----
.../apache/storm/cassandra/query/ContextQuery.java | 96 ----
.../apache/storm/cassandra/query/CqlMapper.java | 81 ----
.../cassandra/query/ObjectMapperOperation.java | 29 --
.../builder/BoundCQLStatementMapperBuilder.java | 98 -----
.../ObjectMapperCqlStatementMapperBuilder.java | 88 ----
.../builder/SimpleCQLStatementMapperBuilder.java | 86 ----
.../query/impl/BatchCQLStatementTupleMapper.java | 50 ---
.../query/impl/BoundCQLStatementTupleMapper.java | 93 ----
.../query/impl/ObjectMapperCqlStatementMapper.java | 134 ------
.../query/impl/PreparedStatementBinder.java | 63 ---
.../cassandra/query/impl/RoutingKeyGenerator.java | 45 --
.../query/impl/SimpleCQLStatementMapper.java | 80 ----
.../cassandra/query/selector/FieldSelector.java | 65 ---
.../trident/state/CassandraBackingMap.java | 235 ----------
.../trident/state/CassandraMapStateFactory.java | 98 -----
.../cassandra/trident/state/CassandraQuery.java | 34 --
.../cassandra/trident/state/CassandraState.java | 150 -------
.../trident/state/CassandraStateFactory.java | 42 --
.../trident/state/CassandraStateUpdater.java | 26 --
.../trident/state/MapStateFactoryBuilder.java | 224 ----------
.../state/NonTransactionalTupleStateMapper.java | 57 ---
.../trident/state/OpaqueTupleStateMapper.java | 119 -----
.../trident/state/SerializedStateMapper.java | 58 ---
.../cassandra/trident/state/SimpleStateMapper.java | 96 ----
.../storm/cassandra/trident/state/SimpleTuple.java | 205 ---------
.../storm/cassandra/trident/state/StateMapper.java | 28 --
.../state/TransactionalTupleStateMapper.java | 98 -----
.../state/TridentAyncCQLResultSetValuesMapper.java | 110 -----
.../state/TridentResultSetValuesMapper.java | 53 ---
.../org/apache/storm/cassandra/WeatherSpout.java | 78 ----
.../testtools/EmbeddedCassandraResource.java | 184 --------
.../storm/cassandra/trident/MapStateTest.java | 216 ---------
.../storm/cassandra/trident/WeatherBatchSpout.java | 95 ----
.../src/test/resources/cassandra.yaml | 39 --
.../storm-cassandra/src/test/resources/schema.cql | 30 --
external/storm-eventhubs/README.md | 45 --
external/storm-eventhubs/pom.xml | 85 ----
.../eventhubs/bolt/DefaultEventDataFormat.java | 47 --
.../apache/storm/eventhubs/bolt/EventHubBolt.java | 139 ------
.../storm/eventhubs/bolt/EventHubBoltConfig.java | 108 -----
.../storm/eventhubs/bolt/IEventDataFormat.java | 29 --
.../eventhubs/spout/BinaryEventDataScheme.java | 72 ---
.../storm/eventhubs/spout/EventDataScheme.java | 75 ----
.../storm/eventhubs/spout/EventDataWrap.java | 48 --
.../storm/eventhubs/spout/EventHubException.java | 41 --
.../storm/eventhubs/spout/EventHubFilter.java | 47 --
.../eventhubs/spout/EventHubReceiverImpl.java | 169 -------
.../storm/eventhubs/spout/EventHubSpout.java | 258 -----------
.../storm/eventhubs/spout/EventHubSpoutConfig.java | 264 -----------
.../storm/eventhubs/spout/FieldConstants.java | 29 --
.../storm/eventhubs/spout/IEventDataScheme.java | 44 --
.../apache/storm/eventhubs/spout/IEventFilter.java | 28 --
.../storm/eventhubs/spout/IEventHubReceiver.java | 34 --
.../eventhubs/spout/IEventHubReceiverFactory.java | 25 --
.../eventhubs/spout/IPartitionCoordinator.java | 28 --
.../storm/eventhubs/spout/IPartitionManager.java | 38 --
.../eventhubs/spout/IPartitionManagerFactory.java | 28 --
.../apache/storm/eventhubs/spout/IStateStore.java | 32 --
.../apache/storm/eventhubs/spout/MessageId.java | 57 ---
.../storm/eventhubs/spout/PartitionManager.java | 101 -----
.../eventhubs/spout/SerializeDeserializeUtil.java | 34 --
.../eventhubs/spout/SimplePartitionManager.java | 133 ------
.../spout/StaticPartitionCoordinator.java | 84 ----
.../eventhubs/spout/StringEventDataScheme.java | 71 ---
.../storm/eventhubs/spout/ZookeeperStateStore.java | 96 ----
.../storm/eventhubs/trident/Coordinator.java | 59 ---
.../trident/ITridentPartitionManager.java | 37 --
.../trident/ITridentPartitionManagerFactory.java | 26 --
.../trident/OpaqueTridentEventHubEmitter.java | 69 ---
.../trident/OpaqueTridentEventHubSpout.java | 63 ---
.../apache/storm/eventhubs/trident/Partition.java | 40 --
.../apache/storm/eventhubs/trident/Partitions.java | 43 --
.../TransactionalTridentEventHubEmitter.java | 161 -------
.../trident/TransactionalTridentEventHubSpout.java | 64 ---
.../eventhubs/trident/TridentPartitionManager.java | 89 ----
.../src/main/resources/config.properties | 45 --
.../eventhubs/samples/AtMostOnceEventCount.java | 54 ---
.../apache/storm/eventhubs/samples/EventCount.java | 144 ------
.../storm/eventhubs/samples/EventHubLoop.java | 52 ---
.../eventhubs/samples/OpaqueTridentEventCount.java | 54 ---
.../samples/TransactionalTridentEventCount.java | 81 ----
.../eventhubs/samples/bolt/GlobalCountBolt.java | 87 ----
.../eventhubs/samples/bolt/PartialCountBolt.java | 67 ---
.../eventhubs/spout/EventHubReceiverMock.java | 84 ----
.../eventhubs/spout/EventHubSpoutCallerMock.java | 92 ----
.../spout/PartitionManagerCallerMock.java | 95 ----
.../eventhubs/spout/SpoutOutputCollectorMock.java | 71 ---
.../storm/eventhubs/spout/StateStoreMock.java | 54 ---
.../storm/eventhubs/spout/TestEventData.java | 48 --
.../storm/eventhubs/spout/TestEventHubSpout.java | 75 ----
.../eventhubs/spout/TestPartitionManager.java | 119 -----
.../trident/TestTransactionalTridentEmitter.java | 92 ----
.../eventhubs/trident/TridentCollectorMock.java | 57 ---
external/storm-hbase/README.md | 315 -------------
external/storm-hbase/pom.xml | 127 ------
.../apache/storm/hbase/bolt/AbstractHBaseBolt.java | 82 ----
.../org/apache/storm/hbase/bolt/HBaseBolt.java | 114 -----
.../apache/storm/hbase/bolt/HBaseLookupBolt.java | 117 -----
.../storm/hbase/bolt/mapper/HBaseMapper.java | 35 --
.../hbase/bolt/mapper/HBaseProjectionCriteria.java | 87 ----
.../storm/hbase/bolt/mapper/HBaseValueMapper.java | 36 --
.../storm/hbase/bolt/mapper/SimpleHBaseMapper.java | 85 ----
.../org/apache/storm/hbase/common/ColumnList.java | 198 ---------
.../org/apache/storm/hbase/common/HBaseClient.java | 181 --------
.../org/apache/storm/hbase/common/IColumn.java | 26 --
.../org/apache/storm/hbase/common/ICounter.java | 24 -
.../java/org/apache/storm/hbase/common/Utils.java | 123 ------
.../storm/hbase/state/HBaseKeyValueState.java | 434 ------------------
.../hbase/state/HBaseKeyValueStateIterator.java | 146 -------
.../hbase/state/HBaseKeyValueStateProvider.java | 165 -------
.../mapper/SimpleTridentHBaseMapMapper.java | 50 ---
.../trident/mapper/SimpleTridentHBaseMapper.java | 79 ----
.../trident/mapper/TridentHBaseMapMapper.java | 34 --
.../hbase/trident/mapper/TridentHBaseMapper.java | 40 --
.../storm/hbase/trident/state/HBaseMapState.java | 264 -----------
.../storm/hbase/trident/state/HBaseQuery.java | 35 --
.../storm/hbase/trident/state/HBaseState.java | 171 --------
.../hbase/trident/state/HBaseStateFactory.java | 34 --
.../storm/hbase/trident/state/HBaseUpdater.java | 27 --
.../hbase/trident/windowing/HBaseWindowsStore.java | 267 -----------
.../windowing/HBaseWindowsStoreFactory.java | 48 --
.../storm/hbase/state/HBaseClientTestUtil.java | 387 ----------------
.../state/HBaseKeyValueStateIteratorTest.java | 203 ---------
.../state/HBaseKeyValueStateProviderTest.java | 86 ----
.../storm/hbase/state/HBaseKeyValueStateTest.java | 115 -----
external/storm-kinesis/README.md | 140 ------
external/storm-kinesis/pom.xml | 73 ----
.../kinesis/spout/CredentialsProviderChain.java | 40 --
.../kinesis/spout/ExponentialBackoffRetrier.java | 169 -------
.../kinesis/spout/FailedMessageRetryHandler.java | 48 --
.../apache/storm/kinesis/spout/KinesisConfig.java | 144 ------
.../storm/kinesis/spout/KinesisConnection.java | 121 -----
.../storm/kinesis/spout/KinesisConnectionInfo.java | 117 -----
.../storm/kinesis/spout/KinesisMessageId.java | 81 ----
.../storm/kinesis/spout/KinesisRecordsManager.java | 486 ---------------------
.../apache/storm/kinesis/spout/KinesisSpout.java | 86 ----
.../storm/kinesis/spout/RecordToTupleMapper.java | 40 --
.../apache/storm/kinesis/spout/ZkConnection.java | 97 ----
.../org/apache/storm/kinesis/spout/ZkInfo.java | 124 ------
.../storm/kinesis/spout/test/KinesisBoltTest.java | 48 --
.../kinesis/spout/test/KinesisSpoutTopology.java | 57 ---
.../spout/test/TestRecordToTupleMapper.java | 58 ---
external/storm-mongodb/README.md | 325 --------------
external/storm-mongodb/pom.xml | 82 ----
.../storm/mongodb/bolt/AbstractMongoBolt.java | 62 ---
.../apache/storm/mongodb/bolt/MongoInsertBolt.java | 124 ------
.../apache/storm/mongodb/bolt/MongoLookupBolt.java | 86 ----
.../apache/storm/mongodb/bolt/MongoUpdateBolt.java | 93 ----
.../apache/storm/mongodb/common/MongoDbClient.java | 109 -----
.../apache/storm/mongodb/common/MongoUtils.java | 44 --
.../storm/mongodb/common/QueryFilterCreator.java | 47 --
.../mongodb/common/SimpleQueryFilterCreator.java | 47 --
.../mongodb/common/mapper/MongoLookupMapper.java | 45 --
.../storm/mongodb/common/mapper/MongoMapper.java | 47 --
.../mongodb/common/mapper/MongoUpdateMapper.java | 26 --
.../common/mapper/SimpleMongoLookupMapper.java | 64 ---
.../mongodb/common/mapper/SimpleMongoMapper.java | 55 ---
.../common/mapper/SimpleMongoUpdateMapper.java | 47 --
.../storm/mongodb/trident/state/MongoMapState.java | 213 ---------
.../storm/mongodb/trident/state/MongoState.java | 145 ------
.../mongodb/trident/state/MongoStateFactory.java | 43 --
.../mongodb/trident/state/MongoStateQuery.java | 41 --
.../mongodb/trident/state/MongoStateUpdater.java | 35 --
external/storm-mqtt/README.md | 375 ----------------
external/storm-mqtt/pom.xml | 148 -------
.../java/org/apache/storm/mqtt/MqttLogger.java | 30 --
.../java/org/apache/storm/mqtt/MqttMessage.java | 37 --
.../org/apache/storm/mqtt/MqttMessageMapper.java | 38 --
.../org/apache/storm/mqtt/MqttTupleMapper.java | 31 --
.../java/org/apache/storm/mqtt/bolt/MqttBolt.java | 97 ----
.../org/apache/storm/mqtt/common/MqttOptions.java | 301 -------------
.../apache/storm/mqtt/common/MqttPublisher.java | 59 ---
.../org/apache/storm/mqtt/common/MqttUtils.java | 82 ----
.../org/apache/storm/mqtt/common/SslUtils.java | 57 ---
.../storm/mqtt/mappers/ByteArrayMessageMapper.java | 31 --
.../storm/mqtt/mappers/StringMessageMapper.java | 34 --
.../apache/storm/mqtt/spout/AckableMessage.java | 70 ---
.../org/apache/storm/mqtt/spout/MqttSpout.java | 270 ------------
.../storm/mqtt/ssl/DefaultKeyStoreLoader.java | 92 ----
.../org/apache/storm/mqtt/ssl/KeyStoreLoader.java | 34 --
.../storm/mqtt/trident/MqttPublishFunction.java | 78 ----
.../storm/mqtt/StormMqttIntegrationTest.java | 145 ------
external/storm-opentsdb/README.md | 76 ----
external/storm-opentsdb/pom.xml | 114 -----
.../storm/opentsdb/OpenTsdbMetricDatapoint.java | 134 ------
.../bolt/ITupleOpenTsdbDatapointMapper.java | 39 --
.../apache/storm/opentsdb/bolt/OpenTsdbBolt.java | 188 --------
.../bolt/TupleOpenTsdbDatapointMapper.java | 135 ------
.../storm/opentsdb/client/ClientResponse.java | 200 ---------
.../storm/opentsdb/client/OpenTsdbClient.java | 155 -------
.../storm/opentsdb/trident/OpenTsdbState.java | 92 ----
.../opentsdb/trident/OpenTsdbStateFactory.java | 52 ---
.../opentsdb/trident/OpenTsdbStateUpdater.java | 37 --
external/storm-pmml/README.md | 61 ---
external/storm-pmml/pom.xml | 103 -----
.../org/apache/storm/pmml/PMMLPredictorBolt.java | 106 -----
.../org/apache/storm/pmml/model/ModelOutputs.java | 47 --
.../storm/pmml/model/jpmml/JpmmlModelOutputs.java | 156 -------
.../org/apache/storm/pmml/runner/ModelRunner.java | 39 --
.../storm/pmml/runner/ModelRunnerFactory.java | 25 --
.../apache/storm/pmml/runner/PmmlModelRunner.java | 56 ---
.../storm/pmml/runner/jpmml/JPmmlModelRunner.java | 156 -------
.../storm/pmml/runner/jpmml/JpmmlFactory.java | 229 ----------
external/storm-pulsar/pom.xml | 277 ------------
.../apache/pulsar/storm/MessageToValuesMapper.java | 45 --
.../java/org/apache/pulsar/storm/PulsarBolt.java | 208 ---------
.../pulsar/storm/PulsarBoltConfiguration.java | 54 ---
.../java/org/apache/pulsar/storm/PulsarSpout.java | 486 ---------------------
.../pulsar/storm/PulsarSpoutConfiguration.java | 195 ---------
.../apache/pulsar/storm/PulsarSpoutConsumer.java | 59 ---
.../pulsar/storm/PulsarStormConfiguration.java | 89 ----
.../java/org/apache/pulsar/storm/PulsarTuple.java | 45 --
.../apache/pulsar/storm/SharedPulsarClient.java | 153 -------
.../apache/pulsar/storm/TupleToMessageMapper.java | 68 ---
.../storm-pulsar/src/main/javadoc/overview.html | 29 --
.../apache/pulsar/storm/MockOutputCollector.java | 101 -----
.../pulsar/storm/MockSpoutOutputCollector.java | 80 ----
.../pulsar/storm/PulsarBoltIntegrationTest.java | 243 -----------
.../pulsar/storm/PulsarSpoutIntegrationTest.java | 354 ---------------
.../org/apache/pulsar/storm/PulsarSpoutTest.java | 178 --------
.../java/org/apache/pulsar/storm/TestUtil.java | 35 --
.../apache/pulsar/storm/example/StormExample.java | 166 -------
external/storm-rocketmq/README.md | 150 -------
external/storm-rocketmq/pom.xml | 90 ----
.../storm/rocketmq/ConsumerBatchMessage.java | 65 ---
.../rocketmq/DefaultMessageBodySerializer.java | 38 --
.../storm/rocketmq/MessageBodySerializer.java | 28 --
.../org/apache/storm/rocketmq/RocketMqConfig.java | 178 --------
.../org/apache/storm/rocketmq/RocketMqUtils.java | 80 ----
.../org/apache/storm/rocketmq/SpoutConfig.java | 29 --
.../apache/storm/rocketmq/bolt/RocketMqBolt.java | 216 ---------
.../mapper/FieldNameBasedTupleToMessageMapper.java | 70 ---
.../common/mapper/TupleToMessageMapper.java | 32 --
.../common/selector/DefaultTopicSelector.java | 45 --
.../selector/FieldNameBasedTopicSelector.java | 70 ---
.../rocketmq/common/selector/TopicSelector.java | 29 --
.../apache/storm/rocketmq/spout/RocketMqSpout.java | 228 ----------
.../rocketmq/spout/scheme/KeyValueScheme.java | 27 --
.../spout/scheme/StringKeyValueScheme.java | 40 --
.../storm/rocketmq/spout/scheme/StringScheme.java | 56 ---
.../rocketmq/trident/state/RocketMqState.java | 132 ------
.../trident/state/RocketMqStateFactory.java | 43 --
.../trident/state/RocketMqStateUpdater.java | 35 --
.../rocketmq/DefaultMessageBodySerializerTest.java | 36 --
.../java/org/apache/storm/rocketmq/TestUtils.java | 45 --
.../storm/rocketmq/bolt/RocketMqBoltTest.java | 67 ---
.../FieldNameBasedTupleToMessageMapperTest.java | 36 --
.../common/selector/DefaultTopicSelectorTest.java | 40 --
.../selector/FieldNameBasedTopicSelectorTest.java | 40 --
.../storm/rocketmq/spout/RocketMqSpoutTest.java | 87 ----
.../spout/scheme/StringKeyValueSchemeTest.java | 63 ---
external/storm-solr/README.md | 224 ----------
external/storm-solr/pom.xml | 158 -------
.../org/apache/storm/solr/bolt/SolrUpdateBolt.java | 165 -------
.../apache/storm/solr/config/CountBasedCommit.java | 53 ---
.../storm/solr/config/SolrCommitStrategy.java | 24 -
.../org/apache/storm/solr/config/SolrConfig.java | 67 ---
.../apache/storm/solr/mapper/SolrFieldsMapper.java | 179 --------
.../apache/storm/solr/mapper/SolrJsonMapper.java | 151 -------
.../org/apache/storm/solr/mapper/SolrMapper.java | 28 --
.../storm/solr/mapper/SolrMapperException.java | 18 -
.../org/apache/storm/solr/schema/CopyField.java | 44 --
.../java/org/apache/storm/solr/schema/Field.java | 44 --
.../org/apache/storm/solr/schema/FieldType.java | 56 ---
.../java/org/apache/storm/solr/schema/Schema.java | 110 -----
.../storm/solr/schema/SolrFieldTypeFinder.java | 187 --------
.../solr/schema/builder/RestJsonSchemaBuilder.java | 70 ---
.../schema/builder/RestJsonSchemaBuilderV2.java | 117 -----
.../storm/solr/schema/builder/SchemaBuilder.java | 23 -
.../org/apache/storm/solr/trident/SolrState.java | 66 ---
.../storm/solr/trident/SolrStateFactory.java | 37 --
.../org/apache/storm/solr/trident/SolrUpdater.java | 26 --
pom.xml | 22 -
sql/pom.xml | 1 -
sql/storm-sql-external/storm-sql-mongodb/pom.xml | 93 ----
.../sql/mongodb/MongoDataSourcesProvider.java | 125 ------
...rg.apache.storm.sql.runtime.DataSourcesProvider | 16 -
.../sql/mongodb/TestMongoDataSourcesProvider.java | 57 ---
377 files changed, 36469 deletions(-)
delete mode 100644 docs/storm-cassandra.md
delete mode 100644 docs/storm-eventhubs.md
delete mode 100644 docs/storm-hbase.md
delete mode 100644 docs/storm-hive.md
delete mode 100644 docs/storm-kinesis.md
delete mode 100644 docs/storm-mongodb.md
delete mode 100644 docs/storm-mqtt.md
delete mode 100644 docs/storm-opentsdb.md
delete mode 100644 docs/storm-pmml.md
delete mode 100644 docs/storm-rocketmq.md
delete mode 100644 docs/storm-solr.md
delete mode 100644 examples/storm-hbase-examples/README.md
delete mode 100644 examples/storm-hbase-examples/pom.xml
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/LookupWordCount.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/PersistentWordCount.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/TotalWordCounter.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCountClient.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCountValueMapper.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordCounter.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/topology/WordSpout.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/trident/PrintFunction.java
delete mode 100644
examples/storm-hbase-examples/src/main/java/org/apache/storm/hbase/trident/WordCountTrident.java
delete mode 100644 examples/storm-mongodb-examples/pom.xml
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/InsertWordCount.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/LookupWordCount.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/TotalWordCounter.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/UpdateWordCount.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/WordCounter.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/topology/WordSpout.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/trident/PrintFunction.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/trident/WordCountTrident.java
delete mode 100644
examples/storm-mongodb-examples/src/main/java/org/apache/storm/mongodb/trident/WordCountTridentMap.java
delete mode 100644 examples/storm-mqtt-examples/pom.xml
delete mode 100644 examples/storm-mqtt-examples/src/main/flux/sample.yaml
delete mode 100644 examples/storm-mqtt-examples/src/main/flux/ssl-sample.yaml
delete mode 100644
examples/storm-mqtt-examples/src/main/java/org/apache/storm/mqtt/examples/CustomMessageMapper.java
delete mode 100644
examples/storm-mqtt-examples/src/main/java/org/apache/storm/mqtt/examples/MqttBrokerPublisher.java
delete mode 100644
examples/storm-mqtt-examples/src/main/java/org/apache/storm/mqtt/examples/package-info.java
delete mode 100644 examples/storm-mqtt-examples/src/main/resources/log4j2.xml
delete mode 100644 examples/storm-opentsdb-examples/pom.xml
delete mode 100644
examples/storm-opentsdb-examples/src/main/java/org/apache/storm/opentsdb/MetricGenBatchSpout.java
delete mode 100644
examples/storm-opentsdb-examples/src/main/java/org/apache/storm/opentsdb/MetricGenSpout.java
delete mode 100644
examples/storm-opentsdb-examples/src/main/java/org/apache/storm/opentsdb/SampleOpenTsdbBoltTopology.java
delete mode 100644
examples/storm-opentsdb-examples/src/main/java/org/apache/storm/opentsdb/SampleOpenTsdbTridentTopology.java
delete mode 100644 examples/storm-pmml-examples/pom.xml
delete mode 100644
examples/storm-pmml-examples/src/main/java/org/apache/storm/pmml/JpmmlRunnerTestTopology.java
delete mode 100644
examples/storm-pmml-examples/src/main/java/org/apache/storm/pmml/RawInputFromCSVSpout.java
delete mode 100644 examples/storm-pmml-examples/src/main/resources/Audit.50.csv
delete mode 100644
examples/storm-pmml-examples/src/main/resources/KNIME_PMML_4.1_Examples_single_audit_logreg.xml
delete mode 100644 examples/storm-pmml-examples/src/main/resources/README.md
delete mode 100644 examples/storm-rocketmq-examples/pom.xml
delete mode 100644
examples/storm-rocketmq-examples/src/main/java/org/apache/storm/rocketmq/topology/WordCountTopology.java
delete mode 100644
examples/storm-rocketmq-examples/src/main/java/org/apache/storm/rocketmq/topology/WordCounter.java
delete mode 100644
examples/storm-rocketmq-examples/src/main/java/org/apache/storm/rocketmq/trident/WordCountTrident.java
delete mode 100644 examples/storm-solr-examples/pom.xml
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/spout/SolrFieldsSpout.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/spout/SolrJsonSpout.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/topology/SolrFieldsTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/topology/SolrJsonTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/topology/SolrTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/trident/SolrFieldsTridentTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/trident/SolrJsonTridentTopology.java
delete mode 100644
examples/storm-solr-examples/src/main/java/org/apache/storm/solr/util/TestUtil.java
delete mode 100644 external/storm-cassandra/README.md
delete mode 100644 external/storm-cassandra/pom.xml
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/AbstractExecutionResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/BaseExecutionResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/CassandraContext.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/DynamicStatementBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/ExecutionResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/Murmur3StreamGrouping.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/BaseCassandraBolt.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/BatchCassandraWriterBolt.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/CassandraWriterBolt.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/GroupingBatchBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/PairBatchStatementTuples.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/bolt/PairStatementTuple.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/CassandraConf.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/ClusterFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/SimpleClient.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/SimpleClientProvider.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/client/impl/DefaultClient.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/context/BaseBeanFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/context/BeanFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/context/WorkerCtx.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/AsyncExecutor.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/AsyncExecutorProvider.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/AsyncResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/AsyncResultSetHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/ExecutionResultCollector.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/impl/BatchAsyncResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/executor/impl/SingleAsyncResultHandler.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/AyncCQLResultSetValuesMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/BaseCQLStatementTupleMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/CQLResultSetValuesMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/CQLStatementBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/CQLStatementTupleMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/Column.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/ContextQuery.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/CqlMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/ObjectMapperOperation.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/builder/BoundCQLStatementMapperBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/builder/ObjectMapperCqlStatementMapperBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/builder/SimpleCQLStatementMapperBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/BatchCQLStatementTupleMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/BoundCQLStatementTupleMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/ObjectMapperCqlStatementMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/PreparedStatementBinder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/RoutingKeyGenerator.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/impl/SimpleCQLStatementMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/query/selector/FieldSelector.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraBackingMap.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraMapStateFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraQuery.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraState.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraStateFactory.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/CassandraStateUpdater.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/MapStateFactoryBuilder.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/NonTransactionalTupleStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/OpaqueTupleStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/SerializedStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/SimpleStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/SimpleTuple.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/StateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/TransactionalTupleStateMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/TridentAyncCQLResultSetValuesMapper.java
delete mode 100644
external/storm-cassandra/src/main/java/org/apache/storm/cassandra/trident/state/TridentResultSetValuesMapper.java
delete mode 100644
external/storm-cassandra/src/test/java/org/apache/storm/cassandra/WeatherSpout.java
delete mode 100644
external/storm-cassandra/src/test/java/org/apache/storm/cassandra/testtools/EmbeddedCassandraResource.java
delete mode 100644
external/storm-cassandra/src/test/java/org/apache/storm/cassandra/trident/MapStateTest.java
delete mode 100644
external/storm-cassandra/src/test/java/org/apache/storm/cassandra/trident/WeatherBatchSpout.java
delete mode 100644 external/storm-cassandra/src/test/resources/cassandra.yaml
delete mode 100644 external/storm-cassandra/src/test/resources/schema.cql
delete mode 100755 external/storm-eventhubs/README.md
delete mode 100755 external/storm-eventhubs/pom.xml
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/bolt/DefaultEventDataFormat.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/bolt/EventHubBolt.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/bolt/EventHubBoltConfig.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/bolt/IEventDataFormat.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/BinaryEventDataScheme.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventDataScheme.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventDataWrap.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubException.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubFilter.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubReceiverImpl.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubSpout.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubSpoutConfig.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/FieldConstants.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IEventDataScheme.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IEventFilter.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IEventHubReceiver.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IEventHubReceiverFactory.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IPartitionCoordinator.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IPartitionManager.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IPartitionManagerFactory.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/IStateStore.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/MessageId.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/PartitionManager.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/SerializeDeserializeUtil.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/SimplePartitionManager.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/StaticPartitionCoordinator.java
delete mode 100644
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/StringEventDataScheme.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/ZookeeperStateStore.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/Coordinator.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/ITridentPartitionManager.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/ITridentPartitionManagerFactory.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/OpaqueTridentEventHubEmitter.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/OpaqueTridentEventHubSpout.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/Partition.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/Partitions.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/TransactionalTridentEventHubEmitter.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/TransactionalTridentEventHubSpout.java
delete mode 100755
external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/trident/TridentPartitionManager.java
delete mode 100755
external/storm-eventhubs/src/main/resources/config.properties
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/AtMostOnceEventCount.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/EventCount.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/EventHubLoop.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/OpaqueTridentEventCount.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/TransactionalTridentEventCount.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/bolt/GlobalCountBolt.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/samples/bolt/PartialCountBolt.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/EventHubReceiverMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/EventHubSpoutCallerMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/PartitionManagerCallerMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/SpoutOutputCollectorMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/StateStoreMock.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/TestEventData.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/TestEventHubSpout.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/spout/TestPartitionManager.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/trident/TestTransactionalTridentEmitter.java
delete mode 100755
external/storm-eventhubs/src/test/java/org/apache/storm/eventhubs/trident/TridentCollectorMock.java
delete mode 100644 external/storm-hbase/README.md
delete mode 100644 external/storm-hbase/pom.xml
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/AbstractHBaseBolt.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/HBaseLookupBolt.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/mapper/HBaseMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/mapper/HBaseProjectionCriteria.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/mapper/HBaseValueMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/bolt/mapper/SimpleHBaseMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/ColumnList.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/HBaseClient.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/IColumn.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/ICounter.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/common/Utils.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/state/HBaseKeyValueState.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/state/HBaseKeyValueStateIterator.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/state/HBaseKeyValueStateProvider.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/mapper/SimpleTridentHBaseMapMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/mapper/SimpleTridentHBaseMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/mapper/TridentHBaseMapMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/mapper/TridentHBaseMapper.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseQuery.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseState.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseStateFactory.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseUpdater.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/windowing/HBaseWindowsStore.java
delete mode 100644
external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/windowing/HBaseWindowsStoreFactory.java
delete mode 100644
external/storm-hbase/src/test/java/org/apache/storm/hbase/state/HBaseClientTestUtil.java
delete mode 100644
external/storm-hbase/src/test/java/org/apache/storm/hbase/state/HBaseKeyValueStateIteratorTest.java
delete mode 100644
external/storm-hbase/src/test/java/org/apache/storm/hbase/state/HBaseKeyValueStateProviderTest.java
delete mode 100644
external/storm-hbase/src/test/java/org/apache/storm/hbase/state/HBaseKeyValueStateTest.java
delete mode 100644 external/storm-kinesis/README.md
delete mode 100644 external/storm-kinesis/pom.xml
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/CredentialsProviderChain.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/ExponentialBackoffRetrier.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/FailedMessageRetryHandler.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisConfig.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisConnection.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisConnectionInfo.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisMessageId.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisRecordsManager.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/KinesisSpout.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/RecordToTupleMapper.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/ZkConnection.java
delete mode 100644
external/storm-kinesis/src/main/java/org/apache/storm/kinesis/spout/ZkInfo.java
delete mode 100644
external/storm-kinesis/src/test/java/org/apache/storm/kinesis/spout/test/KinesisBoltTest.java
delete mode 100644
external/storm-kinesis/src/test/java/org/apache/storm/kinesis/spout/test/KinesisSpoutTopology.java
delete mode 100644
external/storm-kinesis/src/test/java/org/apache/storm/kinesis/spout/test/TestRecordToTupleMapper.java
delete mode 100644 external/storm-mongodb/README.md
delete mode 100644 external/storm-mongodb/pom.xml
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/AbstractMongoBolt.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoInsertBolt.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoLookupBolt.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/bolt/MongoUpdateBolt.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/MongoDbClient.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/MongoUtils.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/QueryFilterCreator.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/SimpleQueryFilterCreator.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/MongoLookupMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/MongoMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/MongoUpdateMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/SimpleMongoLookupMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/SimpleMongoMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/common/mapper/SimpleMongoUpdateMapper.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoMapState.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoState.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoStateFactory.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoStateQuery.java
delete mode 100644
external/storm-mongodb/src/main/java/org/apache/storm/mongodb/trident/state/MongoStateUpdater.java
delete mode 100644 external/storm-mqtt/README.md
delete mode 100644 external/storm-mqtt/pom.xml
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/MqttLogger.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/MqttMessage.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/MqttMessageMapper.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/MqttTupleMapper.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/bolt/MqttBolt.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/common/MqttOptions.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/common/MqttPublisher.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/common/MqttUtils.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/common/SslUtils.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/mappers/ByteArrayMessageMapper.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/mappers/StringMessageMapper.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/spout/AckableMessage.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/spout/MqttSpout.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/ssl/DefaultKeyStoreLoader.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/ssl/KeyStoreLoader.java
delete mode 100644
external/storm-mqtt/src/main/java/org/apache/storm/mqtt/trident/MqttPublishFunction.java
delete mode 100644
external/storm-mqtt/src/test/java/org/apache/storm/mqtt/StormMqttIntegrationTest.java
delete mode 100644 external/storm-opentsdb/README.md
delete mode 100644 external/storm-opentsdb/pom.xml
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/OpenTsdbMetricDatapoint.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/bolt/ITupleOpenTsdbDatapointMapper.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/bolt/OpenTsdbBolt.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/bolt/TupleOpenTsdbDatapointMapper.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/client/ClientResponse.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/client/OpenTsdbClient.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/trident/OpenTsdbState.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/trident/OpenTsdbStateFactory.java
delete mode 100644
external/storm-opentsdb/src/main/java/org/apache/storm/opentsdb/trident/OpenTsdbStateUpdater.java
delete mode 100644 external/storm-pmml/README.md
delete mode 100644 external/storm-pmml/pom.xml
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/PMMLPredictorBolt.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/model/ModelOutputs.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/model/jpmml/JpmmlModelOutputs.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/ModelRunner.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/ModelRunnerFactory.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/PmmlModelRunner.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/jpmml/JPmmlModelRunner.java
delete mode 100644
external/storm-pmml/src/main/java/org/apache/storm/pmml/runner/jpmml/JpmmlFactory.java
delete mode 100644 external/storm-pulsar/pom.xml
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/MessageToValuesMapper.java
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/PulsarBolt.java
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/PulsarBoltConfiguration.java
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/PulsarSpout.java
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/PulsarSpoutConfiguration.java
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/PulsarSpoutConsumer.java
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/PulsarStormConfiguration.java
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/PulsarTuple.java
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/SharedPulsarClient.java
delete mode 100644
external/storm-pulsar/src/main/java/org/apache/pulsar/storm/TupleToMessageMapper.java
delete mode 100644 external/storm-pulsar/src/main/javadoc/overview.html
delete mode 100644
external/storm-pulsar/src/test/java/org/apache/pulsar/storm/MockOutputCollector.java
delete mode 100644
external/storm-pulsar/src/test/java/org/apache/pulsar/storm/MockSpoutOutputCollector.java
delete mode 100644
external/storm-pulsar/src/test/java/org/apache/pulsar/storm/PulsarBoltIntegrationTest.java
delete mode 100644
external/storm-pulsar/src/test/java/org/apache/pulsar/storm/PulsarSpoutIntegrationTest.java
delete mode 100644
external/storm-pulsar/src/test/java/org/apache/pulsar/storm/PulsarSpoutTest.java
delete mode 100644
external/storm-pulsar/src/test/java/org/apache/pulsar/storm/TestUtil.java
delete mode 100644
external/storm-pulsar/src/test/java/org/apache/pulsar/storm/example/StormExample.java
delete mode 100644 external/storm-rocketmq/README.md
delete mode 100644 external/storm-rocketmq/pom.xml
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/ConsumerBatchMessage.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/DefaultMessageBodySerializer.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/MessageBodySerializer.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/RocketMqConfig.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/RocketMqUtils.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/SpoutConfig.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/bolt/RocketMqBolt.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/mapper/FieldNameBasedTupleToMessageMapper.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/mapper/TupleToMessageMapper.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/selector/DefaultTopicSelector.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/selector/FieldNameBasedTopicSelector.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/common/selector/TopicSelector.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/spout/RocketMqSpout.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/spout/scheme/KeyValueScheme.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/spout/scheme/StringKeyValueScheme.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/spout/scheme/StringScheme.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/trident/state/RocketMqState.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/trident/state/RocketMqStateFactory.java
delete mode 100644
external/storm-rocketmq/src/main/java/org/apache/storm/rocketmq/trident/state/RocketMqStateUpdater.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/DefaultMessageBodySerializerTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/TestUtils.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/bolt/RocketMqBoltTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/common/mapper/FieldNameBasedTupleToMessageMapperTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/common/selector/DefaultTopicSelectorTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/common/selector/FieldNameBasedTopicSelectorTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/spout/RocketMqSpoutTest.java
delete mode 100644
external/storm-rocketmq/src/test/java/org/apache/storm/rocketmq/spout/scheme/StringKeyValueSchemeTest.java
delete mode 100644 external/storm-solr/README.md
delete mode 100644 external/storm-solr/pom.xml
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/bolt/SolrUpdateBolt.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/config/CountBasedCommit.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/config/SolrCommitStrategy.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/config/SolrConfig.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/mapper/SolrFieldsMapper.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/mapper/SolrJsonMapper.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/mapper/SolrMapper.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/mapper/SolrMapperException.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/CopyField.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/Field.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/FieldType.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/Schema.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/SolrFieldTypeFinder.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/builder/RestJsonSchemaBuilder.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/builder/RestJsonSchemaBuilderV2.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/schema/builder/SchemaBuilder.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/trident/SolrState.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/trident/SolrStateFactory.java
delete mode 100644
external/storm-solr/src/main/java/org/apache/storm/solr/trident/SolrUpdater.java
delete mode 100644 sql/storm-sql-external/storm-sql-mongodb/pom.xml
delete mode 100644
sql/storm-sql-external/storm-sql-mongodb/src/jvm/org/apache/storm/sql/mongodb/MongoDataSourcesProvider.java
delete mode 100644
sql/storm-sql-external/storm-sql-mongodb/src/resources/META-INF/services/org.apache.storm.sql.runtime.DataSourcesProvider
delete mode 100644
sql/storm-sql-external/storm-sql-mongodb/src/test/org/apache/storm/sql/mongodb/TestMongoDataSourcesProvider.java
