- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Dependencies path like ".*/extern(al)?/.*" 323 files: external/storm-kafka-client/pom.xml external/storm-kafka-client/README.md external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/mapper/FieldNameBasedTupleToKafkaMapper.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/mapper/TupleToKafkaMapper.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/KafkaBolt.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/PreparableCallback.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/selector/FieldNameTopicSelector.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/selector/DefaultTopicSelector.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/selector/FieldIndexTopicSelector.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/selector/KafkaTopicSelector.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/PatternTopicFilter.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/ManualPartitioner.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/RoundRobinManualPartitioner.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/TopicAssigner.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/TopicFilter.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/NamedTopicFilter.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/FirstPollOffsetStrategy.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/TopicPartitionComparator.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/RecordTranslator.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/Func.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/ByTopicRecordTranslator.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetTopicMetrics.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetPartitionMetrics.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetMetricManager.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutMessageId.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaTuple.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/DefaultRecordTranslator.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/SimpleRecordTranslator.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaTupleListener.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/EmptyKafkaTupleListener.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/TopicPartitionSerializer.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitter.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutTransactional.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentOpaqueSpoutEmitter.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutOpaque.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutBatchMetadata.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutTopicPartition.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentTransactionalSpoutEmitter.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutConfig.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutCoordinator.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/internal/OutputFieldsExtractor.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommitMetadata.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/ClientFactory.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommitMetadataManager.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/ClientFactoryDefault.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/Timer.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommonKafkaSpoutConfig.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryService.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/mapper/FieldNameBasedTupleToKafkaMapper.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/mapper/TridentTupleToKafkaMapper.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/TridentKafkaState.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/TridentKafkaStateFactory.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/selector/DefaultTopicSelector.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/selector/KafkaTopicSelector.java external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/TridentKafkaStateUpdater.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/KafkaUnit.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/NullRecordTranslator.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/KafkaUnitExtension.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/bolt/KafkaBoltTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutMessagingGuaranteeTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/MaxUncommittedOffsetTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutReactivationTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/subscription/RoundRobinManualPartitionerTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/subscription/PatternTopicFilterTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/subscription/NamedTopicFilterTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/subscription/TopicAssignerTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutLogCompactionSupportTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/SingleTopicKafkaUnitSetupHelper.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoffTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutRetryLimitTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutRebalanceTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/config/builder/SingleTopicKafkaSpoutConfiguration.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutEmitTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/ByTopicRecordTranslatorTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutNullTupleTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutTopologyDeployActivateDeactivateTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/SimpleRecordTranslatorTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutSingleTopicTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutConfigTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/DefaultRecordTranslatorTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/config/builder/SingleTopicKafkaTridentSpoutConfiguration.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutOpaqueCoordinatorTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitterPartitioningTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutBatchMetadataTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitterEmitTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/internal/OffsetManagerTest.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/SpoutWithMockedConsumerSetupHelper.java external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutAbstractTest.java external/storm-kafka-client/src/test/resources/log4j2.xml external/storm-hdfs/pom.xml external/storm-hdfs/README.md external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/Partitioner.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/NullPartitioner.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/SequenceFileWriter.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/AvroGenericRecordHDFSWriter.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/rotation/RotationAction.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/rotation/MoveFileAction.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/HDFSWriter.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/ModifTimeComparator.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/HdfsUtils.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/AbstractHDFSWriter.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AvroGenericRecordBolt.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/DelimitedRecordFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/FileNameFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/DefaultFileNameFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SequenceFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/DefaultSequenceFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SimpleFileNameFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/RecordFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/sync/CountSyncPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/sync/SyncPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/Writer.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/rotation/FileRotationPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/rotation/TimedRotationPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/rotation/FileSizeRotationPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/rotation/NoRotationPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/HdfsBolt.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/SequenceFileBolt.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/ProgressTracker.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileLock.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/Configs.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileOffset.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileReader.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/ParseException.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/DirLock.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/TextFileReader.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/SequenceFileReader.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/AbstractFileReader.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsStateFactory.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/DelimitedRecordFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/FileNameFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/DefaultFileNameFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/SequenceFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/DefaultSequenceFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/SimpleFileNameFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/RecordFormat.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/sync/CountSyncPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/sync/SyncPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsUpdater.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/rotation/FileRotationPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/rotation/TimedRotationPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/rotation/FileSizeRotationPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/rotation/NoRotationPolicy.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsState.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/AbstractAvroSerializer.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/FixedAvroSerializer.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/AvroUtils.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/AvroSchemaRegistry.java external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/GenericAvroSerializer.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtensionClassLevel.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtension.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/format/TestSimpleFileNameFormat.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/TestSequenceFileBolt.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/AvroGenericRecordBoltTest.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/TestWritersMap.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/TestHdfsBolt.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/ConfigsTest.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestFileLock.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSemantics.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestProgressTracker.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestDirLock.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/trident/format/TestSimpleFileNameFormat.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/trident/HdfsStateTest.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/avro/TestGenericAvroSerializer.java external/storm-hdfs/src/test/java/org/apache/storm/hdfs/avro/TestFixedAvroSerializer.java external/storm-hdfs/src/test/resources/log4j2.xml external/storm-hdfs/src/test/resources/log4j.properties external/storm-blobstore-migration/pom.xml external/storm-blobstore-migration/README.md external/storm-blobstore-migration/src/main/java/org/apache/storm/blobstore/MigratorMain.java external/storm-blobstore-migration/src/main/java/org/apache/storm/blobstore/MigrateBlobs.java external/storm-blobstore-migration/src/main/java/org/apache/storm/blobstore/ListHDFS.java external/storm-blobstore-migration/src/main/java/org/apache/storm/blobstore/ListLocalFs.java external/storm-blobstore-migration/migrate.sh external/storm-blobstore-migration/listHDFS.sh external/storm-blobstore-migration/listLocal.sh external/storm-kafka-migration/pom.xml external/storm-kafka-migration/README.md external/storm-kafka-migration/src/main/conf/example-spout-migration-config.yaml external/storm-kafka-migration/src/main/conf/example-trident-spout-migration-config.yaml external/storm-kafka-migration/src/main/java/org/apache/storm/kafka/migration/MapUtil.java external/storm-kafka-migration/src/main/java/org/apache/storm/kafka/migration/KafkaTridentSpoutMigration.java external/storm-kafka-migration/src/main/java/org/apache/storm/kafka/migration/KafkaSpoutMigration.java external/README.md external/storm-metrics-prometheus/pom.xml external/storm-metrics-prometheus/README.md external/storm-metrics-prometheus/src/main/java/org/apache/storm/metrics/prometheus/PrometheusReporterClient.java external/storm-metrics-prometheus/src/main/java/org/apache/storm/metrics/prometheus/PrometheusPreparableReporter.java external/storm-metrics-prometheus/src/test/java/org/apache/storm/metrics/prometheus/PrometheusPreparableReporterTest.java external/storm-metrics-prometheus/src/test/resources/pushgateway-ssl.yaml external/storm-metrics-prometheus/src/test/resources/pushgateway-basicauth.yaml external/storm-hdfs-blobstore/pom.xml external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStoreFile.java external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsClientBlobStore.java external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStoreImpl.java external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStore.java external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/blobstore/BlobStoreTest.java external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/blobstore/HdfsBlobStoreImplTest.java external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtensionClassLevel.java external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtension.java external/storm-jms/pom.xml external/storm-jms/README.markdown external/storm-jms/src/main/java/org/apache/storm/jms/bolt/JmsBolt.java external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsMessageID.java external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsSpout.java external/storm-jms/src/main/java/org/apache/storm/jms/JmsMessageProducer.java external/storm-jms/src/main/java/org/apache/storm/jms/trident/JmsStateFactory.java external/storm-jms/src/main/java/org/apache/storm/jms/trident/JmsState.java external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java external/storm-jms/src/main/java/org/apache/storm/jms/trident/JmsUpdater.java external/storm-jms/src/main/java/org/apache/storm/jms/trident/JmsBatch.java external/storm-jms/src/main/java/org/apache/storm/jms/JmsTupleProducer.java external/storm-jms/src/main/java/org/apache/storm/jms/JmsProvider.java external/storm-jms/src/test/java/org/apache/storm/jms/spout/MockSpoutOutputCollector.java external/storm-jms/src/test/java/org/apache/storm/jms/spout/MockTupleProducer.java external/storm-jms/src/test/java/org/apache/storm/jms/spout/MockJmsProvider.java external/storm-jms/src/test/java/org/apache/storm/jms/spout/JmsSpoutTest.java external/storm-jms/src/test/resources/jndi.properties external/storm-hdfs-oci/pom.xml external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/HdfsOciResourcesLocalizer.java external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/LocalOrHdfsImageTagToManifestPlugin.java external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/HdfsManifestToResourcesPlugin.java external/storm-jdbc/pom.xml external/storm-jdbc/README.md external/storm-jdbc/src/main/java/org/apache/storm/jdbc/mapper/SimpleJdbcMapper.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/mapper/JdbcLookupMapper.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/mapper/SimpleJdbcLookupMapper.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/mapper/JdbcMapper.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/ConnectionProvider.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/Util.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/JdbcClient.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/Column.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/HikariCPConnectionProvider.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/bolt/JdbcInsertBolt.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/bolt/JdbcLookupBolt.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/bolt/AbstractJdbcBolt.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcQuery.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcStateFactory.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcState.java external/storm-jdbc/src/main/java/org/apache/storm/jdbc/trident/state/JdbcUpdater.java external/storm-jdbc/src/test/java/org/apache/storm/jdbc/common/JdbcClientTest.java external/storm-jdbc/src/test/java/org/apache/storm/jdbc/common/UtilTest.java external/storm-jdbc/src/test/java/org/apache/storm/jdbc/bolt/JdbcLookupBoltTest.java external/storm-jdbc/src/test/java/org/apache/storm/jdbc/bolt/JdbcInsertBoltTest.java external/storm-redis/pom.xml external/storm-redis/README.md external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueStateProvider.java external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueStateIterator.java external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/TupleMapper.java external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisDataTypeDescription.java external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisStoreMapper.java external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisFilterMapper.java external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisMapper.java external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisLookupMapper.java external/storm-redis/src/main/java/org/apache/storm/redis/common/config/JedisPoolConfig.java external/storm-redis/src/main/java/org/apache/storm/redis/common/config/JedisClusterConfig.java external/storm-redis/src/main/java/org/apache/storm/redis/common/commands/RedisCommands.java external/storm-redis/src/main/java/org/apache/storm/redis/common/container/RedisCommandsInstanceContainer.java external/storm-redis/src/main/java/org/apache/storm/redis/common/container/RedisContainer.java external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisClusterContainer.java external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisContainer.java external/storm-redis/src/main/java/org/apache/storm/redis/common/container/RedisCommandsContainerBuilder.java external/storm-redis/src/main/java/org/apache/storm/redis/common/container/RedisClusterContainer.java external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisCommandsContainerBuilder.java external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisCommandsContainer.java external/storm-redis/src/main/java/org/apache/storm/redis/common/adapter/RedisCommandsAdapterJedis.java external/storm-redis/src/main/java/org/apache/storm/redis/common/adapter/RedisCommandsAdapterJedisCluster.java external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisLookupBolt.java external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisStoreBolt.java external/storm-redis/src/main/java/org/apache/storm/redis/bolt/AbstractRedisBolt.java external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisFilterBolt.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisStateUpdater.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisStateQuerier.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterStateQuerier.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterState.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisStateUpdater.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/KeyFactory.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisMapState.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterStateUpdater.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisStateQuerier.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/Options.java external/storm-redis/src/test/java/org/apache/storm/redis/state/RedisKeyValueStateTest.java external/storm-redis/src/test/java/org/apache/storm/redis/state/RedisKeyValueStateIteratorTest.java external/storm-redis/src/test/java/org/apache/storm/redis/state/RedisKeyValueStateProviderTest.java external/storm-redis/src/test/java/org/apache/storm/redis/util/JedisTestHelper.java external/storm-redis/src/test/java/org/apache/storm/redis/util/outputcollector/StubOutputCollector.java external/storm-redis/src/test/java/org/apache/storm/redis/util/outputcollector/EmittedTuple.java external/storm-redis/src/test/java/org/apache/storm/redis/util/TupleTestHelper.java external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java external/storm-redis/src/test/java/org/apache/storm/redis/bolt/RedisFilterBoltTest.java external/storm-autocreds/pom.xml external/storm-autocreds/src/main/java/org/apache/storm/common/HadoopCredentialUtil.java external/storm-autocreds/src/main/java/org/apache/storm/common/AbstractHadoopNimbusPluginAutoCreds.java external/storm-autocreds/src/main/java/org/apache/storm/common/AbstractHadoopAutoCreds.java external/storm-autocreds/src/main/java/org/apache/storm/common/CredentialKeyProvider.java external/storm-autocreds/src/main/java/org/apache/storm/hdfs/security/AutoHDFS.java external/storm-autocreds/src/main/java/org/apache/storm/hdfs/security/HdfsSecurityUtil.java external/storm-autocreds/src/main/java/org/apache/storm/hdfs/security/AutoHDFSCommand.java external/storm-autocreds/src/main/java/org/apache/storm/hdfs/security/AutoHDFSNimbus.java external/storm-autocreds/src/main/java/org/apache/storm/hbase/security/AutoHBaseNimbus.java external/storm-autocreds/src/main/java/org/apache/storm/hbase/security/AutoHBaseCommand.java external/storm-autocreds/src/main/java/org/apache/storm/hbase/security/HBaseSecurityUtil.java external/storm-autocreds/src/main/java/org/apache/storm/hbase/security/AutoHBase.java external/storm-kafka-monitor/pom.xml external/storm-kafka-monitor/README.md external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaPartitionOffsetLag.java external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/NewKafkaSpoutOffsetQuery.java external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaOffsetLagUtil.java external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaOffsetLagResult.java external/storm-metrics/pom.xml external/storm-metrics/src/main/java/org/apache/storm/metrics/sigar/CPUMetric.java external/storm-metrics/src/main/java/org/apache/storm/metrics/hdrhistogram/HistogramMetric.java - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Documentation path like ".*/docs/.*" 89 files: docs/LocalityAwareness.md docs/flux.md docs/Message-passing-implementation.md docs/Installing-native-dependencies.md docs/Joins.md docs/storm-hdfs.md docs/Guaranteeing-message-processing.md docs/Structure-of-the-codebase.md docs/Performance.md docs/Project-ideas.md docs/windows-users-guide.md docs/nimbus-ha-design.md docs/Setting-up-a-Storm-cluster.md docs/Maven.md docs/Using-non-JVM-languages-with-Storm.md docs/Trident-tutorial.md docs/metrics_v2.md docs/README.md docs/Serializers.md docs/storm-redis.md docs/Common-patterns.md docs/Kestrel-and-Storm.md docs/Setting-up-a-Storm-project-in-Eclipse.md docs/storm-sql-internal.md docs/Support-for-non-java-languages.md docs/Hooks.md docs/Configuration.md docs/Generic-resources.md docs/Serialization.md docs/Defining-a-non-jvm-language-dsl-for-storm.md docs/storm-sql.md docs/Storm-Scheduler.md docs/index.md docs/Pacemaker.md docs/cgroups_in_storm.md docs/storm-jms-example.md docs/dynamic-log-level-settings.md docs/Rationale.md docs/Implementation-docs.md docs/Command-line-client.md docs/Clojure-DSL.md docs/Running-topologies-on-a-production-cluster.md docs/Setting-up-development-environment.md docs/Tutorial.md docs/Spout-implementations.md docs/Concepts.md docs/storm-sql-reference.md docs/Multilang-protocol.md docs/Stream-API.md docs/Troubleshooting.md docs/Daemon-Fault-Tolerance.md docs/Metrics.md docs/OCI-support.md docs/Trident-spouts.md docs/Understanding-the-parallelism-of-a-Storm-topology.md docs/SECURITY.md docs/Serialization-(prior-to-0.6.0).md docs/Contributing-to-Storm.md docs/FAQ.md docs/Trident-state.md docs/Fault-tolerance.md docs/Trident-API-Overview.md docs/State-checkpointing.md docs/Creating-a-new-Storm-project.md docs/Classpath-handling.md docs/STORM-UI-REST-API.md docs/storm-jms-spring.md docs/distcache-blobstore.md docs/Acking-framework-implementation.md docs/Distributed-RPC.md docs/Storm-multi-language-protocol-(versions-0.7.0-and-below).md docs/ClusterMetrics.md docs/NUMA.md docs/Windowing.md docs/Transactional-topologies.md docs/storm-jdbc.md docs/images/topology_dark.svg docs/images/topology.svg docs/Trident-RAS-API.md docs/storm-jms.md docs/Logs.md docs/IConfigLoader.md docs/DSLs-and-multilang-adapters.md docs/Local-mode.md docs/Docker-support.md docs/Eventlogging.md docs/storm-metricstore.md docs/Lifecycle-of-a-topology.md docs/dynamic-worker-profiling.md - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long lines (1000+ characters) 30 files: licenses/Jersey CDDL 1.1.html licenses/Common Public License 1.0.txt licenses/The MIT License.html licenses/BSD 2-clause.html licenses/Eclipse Public License 1.0.txt storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/bootstrap-3.3.1.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/jquery.blockUI.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/url.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/typeahead.jquery.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/esprima.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/jquery.cookies.2.2.0.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/vis.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/jquery-3.5.1.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/js-yaml.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/dagre.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/cytoscape.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/jsonFormatter.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/moment.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/css/bootstrap-3.3.1.min.css storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/css/jquery.dataTables.1.10.4.min.css storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/css/vis.min.css storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/css/jsonFormatter.min.css docs/Resource_Aware_Scheduler_overview.md docs/storm-kafka-client.md docs/storm-sql-example.md docs/images/spout.svg docs/images/resource_aware_scheduler_default_eviction_strategy.svg docs/images/storm-sql-internal-example-exported-from-drawio.xml docs/images/bolt.svg docs/images/storm-sql-internal-workflow-exported-from-drawio.xml - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Hidden files and folders path like ".*/[.][a-zA-Z0-9_]+.*" 8 files: .github/workflows/maven.yaml .github/workflows/snapshots.yaml .github/workflows/nightlies.yaml .github/pull_request_template.md .gitignore .asf.yaml storm-core/src/native/worker-launcher/.autom4te.cfg .gitattributes - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Binaries for distribution path like ".*/bin/.*" 6 files: bin/flight.bash bin/storm.ps1 bin/test_storm.py bin/docker-to-squash.py bin/storm.py bin/test_docker_to_squash.py - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long file (1000000+ bytes) 6 files: examples/storm-perf/src/main/sampledata/randomwords.txt storm-client/src/jvm/org/apache/storm/generated/Nimbus.java docs/images/architecture.svg docs/images/security.svg docs/images/storm.svg git-history.txt - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too many lines (10000) 2 files: storm-client/src/py/storm/ttypes.py storm-client/src/py/storm/Nimbus.py - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Minimized JS library path like ".*[.]min[.]js" 2 files: storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/dataTables.bootstrap.min.js storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/jquery.dataTables.1.10.4.min.js - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Bootstrap path like ".*[.]bootstrap[.](js|css|less|scss|styl)" 1 files: storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/css/dataTables.bootstrap.css - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - jQuery files path like "(?i).*/jquery.*[.]js" 1 files: storm-webapp/src/main/java/org/apache/storm/daemon/ui/WEB-INF/js/jquery.mustache.js - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -