This is an automated email from the ASF dual-hosted git repository. rzo1 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/storm.git
commit 51480142b16dfd1030816cfd29a6699209a1d9a6 Merge: c9e181c83 d2e670a66 Author: Richard Zowalla <[email protected]> AuthorDate: Mon Oct 23 16:28:55 2023 +0200 Merge pull request #3588 from apache/STORM-3988 STORM-3988 - Removal of modules residing in /external 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(-)
