Path	Lines of Code
connectors/aliyun/rocketmq-connect-dingtalk/src/test/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnectorTest.java	43
connectors/aliyun/rocketmq-connect-eventbridge/src/test/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkTest.java	73
connectors/aliyun/rocketmq-connect-fc/src/test/java/org/apache/rocketmq/connect/fc/sink/FcSinkConnectorTest.java	27
connectors/aliyun/rocketmq-connect-fc/src/test/java/org/apache/rocketmq/connect/fc/sink/FcSinkTaskTest.java	109
connectors/aliyun/rocketmq-connect-mns/src/test/java/org/apache/rocketmq/connect/mns/source/MNSSourceConnectorTest.java	44
connectors/aliyun/rocketmq-connect-rocketmq/src/test/java/org/apache/rocketmq/connect/rocketmq/RocketMQSinkConnectorTest.java	77
connectors/aliyun/rocketmq-connect-rocketmq/src/test/java/org/apache/rocketmq/connect/rocketmq/RocketMQSourceConnectorTest.java	66
connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java	42
connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java	23
connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java	121
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/common/CloneUtilsTest.java	12
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/common/DBUtilsTest.java	18
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/common/TestClone.java	12
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/common/UtilsTest.java	46
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtilTest.java	17
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnectorTest.java	40
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTaskTest.java	26
connectors/rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnectorTest.java	45
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/test/java/org/apache/rocketmq/connect/kafka/connect/adaptor/SourceRecordConverterTest.java	177
connectors/rocketmq-connect-elasticsearch/src/test/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConfigTest.java	24
connectors/rocketmq-connect-elasticsearch/src/test/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSourceConnectorTest.java	22
connectors/rocketmq-connect-elasticsearch/src/test/java/org/apache/rocketmq/connect/elasticsearch/replicator/source/ElasticsearchQueryTest.java	24
connectors/rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/config/HiveConfigTest.java	17
connectors/rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/config/HiveJdbcDriverManagerTest.java	19
connectors/rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/connector/HiveSourceConnectorTest.java	39
connectors/rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/connector/HiveSourceTaskTest.java	74
connectors/rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/replicator/source/HiveQueryTest.java	31
connectors/rocketmq-connect-http/src/test/java/org/apache/rocketmq/connect/http/sink/HttpSinkConnectorTest.java	34
connectors/rocketmq-connect-hudi/src/test/java/Producer.java	44
connectors/rocketmq-connect-hudi/src/test/java/user.avsc	9
connectors/rocketmq-connect-iotdb/src/test/java/org/apache/rocketmq/connect/iotdb/config/IotdbConfigTest.java	19
connectors/rocketmq-connect-iotdb/src/test/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceConnectorTest.java	27
connectors/rocketmq-connect-iotdb/src/test/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceTaskTest.java	38
connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/sink/OpenMLDBJdbcSinkTest.java	4
connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/source/JdbcSourceConnectorTest.java	3
connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/source/JdbcSourceTaskTest.java	16
connectors/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java	33
connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java	33
connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java	19
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java	57
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java	130
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java	72
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java	104
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java	117
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java	16
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java	27
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java	49
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java	48
connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/TestPositionStorageReader.java	14
connectors/rocketmq-connect-mqtt/src/test/java/connector/MqttSinkConnectorTest.java	28
connectors/rocketmq-connect-mqtt/src/test/java/connector/MqttSinkTaskTest.java	96
connectors/rocketmq-connect-mqtt/src/test/java/connector/MqttSourceConnectorTest.java	25
connectors/rocketmq-connect-mqtt/src/test/java/connector/MqttSourceTaskTest.java	116
connectors/rocketmq-connect-mqtt/src/test/java/sink/UpdaterTest.java	74
connectors/rocketmq-connect-mqtt/src/test/java/source/ReplicatorTest.java	35
connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java	5
connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java	15
connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java	78
connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java	19
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java	84
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java	26
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java	28
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java	92
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/TestPositionStorageReader.java	14
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/TestSourceTaskContext.java	19
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java	78
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java	399
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java	998
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java	16
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java	62
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java	29
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java	114
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java	160
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java	40
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java	97
connectors/rocketmq-replicator/src/test/java/org/apache/rocketmq/replicator/DefaultTaskDivideStrategyTest.java	204
connectors/rocketmq-replicator/src/test/java/org/apache/rocketmq/replicator/RmqSourceReplicatorTest.java	27
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValueTest.java	50
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/common/FastJsonTest.java	23
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/config/ConnectConfigTest.java	73
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/config/SinkConnectorConfigTest.java	25
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/NameServerMocker.java	25
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/RecordOffsetManagementTest.java	60
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/ServerResponseMocker.java	211
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/SourceTaskOffsetCommitterTest.java	52
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TestTransform.java	18
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TransformChainTest.java	37
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnectorTest.java	35
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTaskTest.java	99
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTaskContextTest.java	56
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTaskTest.java	94
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTaskTest.java	86
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTest.java	186
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestConnector.java	31
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestConverter.java	14
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestPositionManageServiceImpl.java	47
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestPositionStorageReader.java	16
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestSinkTask.java	17
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestSourceTask.java	34
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java	18
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/distributed/DistributedConnectControllerTest.java	70
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/distributed/TestConfigManagementService.java	58
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/distributed/TestStateManagementService.java	49
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginClassLoaderTest.java	22
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginTest.java	26
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginUtilsTest.java	35
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginWrapperTest.java	17
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/TestFileSystem.java	61
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/isolation/TestPath.java	135
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/controller/standalone/StandaloneConnectControllerTest.java	61
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/AbstractRecordConverterTest.java	6
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/ByteArrayConverterTest.java	22
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/ConverterConfigTest.java	21
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/DoubleConverterTest.java	19
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/IntegerConverterTest.java	19
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/JsonConverterConfigTest.java	16
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/JsonConverterTest.java	746
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/LongConverterTest.java	19
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/ShortConverterTest.java	19
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/StringConverterTest.java	19
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/errors/DeadLetterQueueReporterTest.java	68
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/errors/ProcessingContextTest.java	17
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/errors/ReporterManagerUtilTest.java	41
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/errors/RetryWithToleranceOperatorTest.java	69
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/errors/WorkerErrorRecordReporterTest.java	46
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/rest/RestHandlerTest.java	255
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/FloatDeserializerTest.java	17
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/FloatSerializerTest.java	17
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/JsonSerdeTest.java	25
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/ListSerdeTest.java	24
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/RecordOffsetSerdeTest.java	25
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/RecordPartitionSerdeTest.java	26
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/store/ConnectKeyValueDeserializerTest.java	17
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/store/ConnectKeyValueSerdeTest.java	11
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/store/ConnectKeyValueSerializerTest.java	16
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/store/RecordPositionMapDeserializerTest.java	29
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/store/RecordPositionMapSerdeTest.java	18
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/serialization/store/RecordPositionMapSerializerfTest.java	26
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementServiceImplTest.java	77
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementServiceImplTest.java	175
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/DefaultConnectorContextTest.java	80
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/PositionManagementServiceImplTest.java	210
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/memory/FilePositionManagementServiceImplTest.java	61
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImplTest.java	86
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryStateManagementServiceImplTest.java	45
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategyByConsistentHashTest.java	87
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/strategy/DefaultAllocateConnAndTaskStrategyTest.java	81
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/store/FileBaseKeyValueStoreTest.java	20
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/store/PositionStorageReaderImplTest.java	94
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/store/PositionStorageWriterTest.java	71
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/Base64UtilTest.java	13
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtilTest.java	148
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/CountDownLatch2Test.java	33
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/FileAndPropertyUtilTest.java	108
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/ServerUtilTest.java	50
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/ServiceProviderUtilTest.java	41
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/TestUtils.java	18
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/TransferUtilsTest.java	98
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/UtilsTest.java	26
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLogTest.java	86
schema-converter/avro-schema-converter/src/test/java/com/apache/rocketmq/schema/avro/test/AvroConverterTest.java	28
schema-converter/json-schema-converter/src/test/java/org/apache/rocketmq/schema/json/test/JsonSchemaConverterTest.java	22
schema-converter/schema-converter-common/src/test/java/com/apache/rocketmq/schema/common/BaseRegistrySchema.java	10
schema-converter/schema-converter-common/src/test/java/com/apache/rocketmq/schema/common/GetRecordByRecordIdTest.java	22
schema-converter/schema-converter-common/src/test/java/com/apache/rocketmq/schema/common/RegistrySchemaTest.java	19
schema-converter/schema-converter-common/src/test/java/com/apache/rocketmq/schema/common/SameSchemaNameTest.java	16
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/ChangeCaseTest.java	61
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/ExtractNestedFieldTest.java	83
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/PatternFilterTest.java	66
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/PatternRenameTest.java	115
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/SetMaximumPrecisionTest.java	109
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/SetNullTest.java	27
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/TransformationTest.java	17
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/common/AssertSchema.java	86
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/common/AssertStruct.java	89
transforms/src/test/java/org/apache/rocketmq/connect/transforms/test/common/GenericAssertions.java	80