Path	Lines of Code
connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnector.java	50
connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkTask.java	63
connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java	205
connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/constant/DingTalkConstant.java	10
connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java	68
connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkTask.java	112
connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/constant/EventBridgeConstant.java	15
connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/utils/CheckUtils.java	20
connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/utils/DateUtils.java	18
connectors/aliyun/rocketmq-connect-fc/src/main/java/org/apache/rocketmq/connect/fc/sink/FcSinkConnector.java	60
connectors/aliyun/rocketmq-connect-fc/src/main/java/org/apache/rocketmq/connect/fc/sink/FcSinkTask.java	101
connectors/aliyun/rocketmq-connect-fc/src/main/java/org/apache/rocketmq/connect/fc/sink/constant/FcConstant.java	12
connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/AbstractMNSRecordConvert.java	37
connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/MNSRecordConverImpl.java	41
connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/MNSSourceConnector.java	72
connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/MNSSourceTask.java	121
connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/constant/MNSConstant.java	10
connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/utils/AliyunMnsUtil.java	16
connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/RocketMQSinkConnector.java	83
connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/RocketMQSinkTask.java	91
connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/RocketMQSourceConnector.java	96
connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/RocketMQSourceTask.java	123
connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/common/RocketMQConstant.java	11
connectors/aliyun/rocketmq-connect-rocketmq/src/main/java/org/apache/rocketmq/connect/rocketmq/utils/OnsUtils.java	7
connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java	117
connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java	5
connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java	33
connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java	31
connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java	149
connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java	64
connectors/rocketmq-connect-cassandra/scripts/gen_data.py	90
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/CloneUtils.java	25
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/ConstDefine.java	8
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DBUtils.java	49
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DataType.java	8
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java	48
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java	199
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java	46
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/DbConnectorConfig.java	70
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SinkDbConnectorConfig.java	69
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SourceDbConnectorConfig.java	52
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskDivideConfig.java	78
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskTopicInfo.java	15
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java	177
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java	79
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnector.java	62
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java	167
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java	86
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Schema.java	81
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Table.java	64
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BigIntColumnParser.java	24
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java	13
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/ColumnParser.java	79
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DateTimeColumnParser.java	27
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DefaultColumnParser.java	14
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/EnumColumnParser.java	22
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/IntColumnParser.java	39
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/SetColumnParser.java	28
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/StringColumnParser.java	30
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/TimeColumnParser.java	15
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/YearColumnParser.java	17
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/sink/Updater.java	164
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java	138
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java	5
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideTaskByTopic.java	94
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/TaskDivideStrategy.java	8
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/config/ConnectKeyValue.java	80
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/connector/AbstractKafkaSinkConnector.java	58
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/connector/AbstractKafkaSourceConnector.java	58
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/connector/ConnectorClassSetter.java	9
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/connector/KafkaConnectorContext.java	16
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/connector/KafkaSinkAdaptorConnector.java	18
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/connector/KafkaSourceAdaptorConnector.java	18
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/context/KafkaOffsetStorageReader.java	42
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/context/RocketMQKafkaErrantRecordReporter.java	20
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/context/RocketMQKafkaSinkTaskContext.java	99
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/context/RocketMQKafkaSourceTaskContext.java	20
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/Converters.java	126
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/KafkaSinkSchemaConverter.java	297
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/KafkaSinkValueConverter.java	97
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/RocketMQSourceSchemaConverter.java	295
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/RocketMQSourceValueConverter.java	98
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/AbstractKafkaConnectSink.java	66
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/AbstractKafkaConnectSource.java	84
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/KafkaConnectAdaptorSink.java	31
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/KafkaConnectAdaptorSource.java	32
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/TaskClassSetter.java	9
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/transforms/TransformationWrapper.java	58
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/DebeziumConnector.java	4
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/DebeziumSource.java	15
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqAdminUtil.java	182
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqConfig.java	86
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqDatabaseHistory.java	269
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/ZeroMessageQueueSelector.java	12
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mongodb/src/main/java/org/apache/rocketmq/connect/debezium/mongodb/DebeziumMongoDBConnector.java	14
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mongodb/src/main/java/org/apache/rocketmq/connect/debezium/mongodb/DebeziumMongoDBSource.java	9
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mongodb/src/main/resources/debezium-mongodb-source-config.yaml	1
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/MySqlReadOnlyIncrementalSnapshotChangeEventSource.java	166
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/MySqlReadOnlyIncrementalSnapshotContext.java	120
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/signal/ExecuteSnapshotRocketMqSignal.java	16
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/signal/RocketMqSignalThread.java	175
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/org/apache/rocketmq/connect/debezium/mysql/DebeziumMysqlConnector.java	14
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/org/apache/rocketmq/connect/debezium/mysql/DebeziumMysqlSource.java	9
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/resources/debezium-mysql-source-config.yaml	30
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-oracle/src/main/java/org/apache/rocketmq/connect/debezium/oracle/DebeziumOracleConnector.java	14
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-oracle/src/main/java/org/apache/rocketmq/connect/debezium/oracle/DebeziumOracleSource.java	9
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-oracle/src/main/resources/debezium-oracle-source-config.yaml	1
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-postgresql/src/main/java/org/apache/rocketmq/connect/debezium/postgres/DebeziumPostgresConnector.java	14
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-postgresql/src/main/java/org/apache/rocketmq/connect/debezium/postgres/DebeziumPostgresSource.java	9
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-postgresql/src/main/resources/debezium-postgres-source-config.yaml	1
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-sqlserver/src/main/java/org/apache/rocketmq/connect/debezium/sqlserver/DebeziumSqlServerConnector.java	14
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-sqlserver/src/main/java/org/apache/rocketmq/connect/debezium/sqlserver/DebeziumSqlServerSource.java	9
connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-sqlserver/src/main/resources/debezium-sqlserver-source-config.yaml	1
connectors/rocketmq-connect-deltalake/src/main/java/example/avro/User.java	287
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/config/ConfigUtil.java	47
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/config/DeltalakeConnectConfig.java	86
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/connector/DeltalakeSinkConnector.java	26
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/connector/DeltalakeSinkTask.java	47
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/exception/WriteParquetException.java	6
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/rolling/DailyRolling.java	43
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/rolling/StoreFileRolling.java	7
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/writer/DeltalakeWriter.java	7
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/writer/DeltalakeWriterOnHdfs.java	186
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/writer/WriteParquetResult.java	53
connectors/rocketmq-connect-deltalake/style/rmq_checkstyle.xml	86
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/config/AbstractConfig.java	73
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector/DorisSinkConfig.java	247
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector/DorisSinkConnector.java	35
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector/DorisSinkTask.java	65
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/exception/ConfigException.java	13
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/exception/DorisException.java	13
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/exception/TableAlterOrCreateException.java	10
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnDefAdjuster.java	49
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnDefinition.java	149
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnId.java	72
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/parser/DateColumnParser.java	38
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/parser/TimeColumnParser.java	39
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/parser/TimestampColumnParser.java	28
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/db/DbStructure.java	17
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/table/TableDefinition.java	35
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/table/TableDefinitions.java	28
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/table/TableId.java	113
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/ByteArrayDeserializer.java	7
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/ByteArraySerializer.java	7
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/ByteBufferDeserializer.java	11
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/ByteBufferSerializer.java	21
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/Deserializer.java	15
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/DoubleDeserializer.java	18
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/DoubleSerializer.java	20
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/FloatDeserializer.java	19
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/FloatSerializer.java	16
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/IntegerDeserializer.java	19
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/IntegerSerializer.java	15
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/JsonDeserializer.java	21
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/JsonSerializer.java	19
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/LongDeserializer.java	19
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/LongSerializer.java	19
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/Serializer.java	15
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/ShortDeserializer.java	19
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/ShortSerializer.java	13
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/StringDeserializer.java	25
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/StringSerializer.java	28
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/BufferedRecords.java	182
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/DorisDialect.java	102
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/DorisStreamLoader.java	83
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/RecordValidator.java	70
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/Updater.java	48
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata/FieldsMetadata.java	244
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata/SchemaPair.java	38
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata/SinkRecordField.java	59
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/BytesUtil.java	12
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ConnectorGroupUtils.java	27
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/DateTimeUtils.java	44
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/ExpressionBuilder.java	247
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/IdentifierRules.java	96
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/JdbcDriverInfo.java	63
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/NumericMapping.java	19
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/QuoteMethod.java	21
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/TableType.java	53
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util/TableUtil.java	13
connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConfig.java	110
connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConstant.java	14
connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSinkConnector.java	41
connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSinkTask.java	176
connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSourceConnector.java	56
connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSourceTask.java	120
connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/replicator/source/ElasticsearchQuery.java	129
connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/replicator/source/ElasticsearchReplicator.java	35
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveColumn.java	36
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveConfig.java	107
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveConstant.java	17
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveJdbcDriverManager.java	48
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/HiveRecord.java	18
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/SchemaManger.java	21
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/connector/HiveSourceConnector.java	81
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/connector/HiveSourceTask.java	104
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/replicator/source/HiveQuery.java	91
connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/replicator/source/HiveReplicator.java	35
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/HttpSinkConnector.java	49
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/HttpSinkTask.java	33
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java	200
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/constant/HttpConstant.java	5
connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java	28
connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java	46
connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java	114
connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java	115
connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java	48
connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java	66
connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java	71
connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java	222
connectors/rocketmq-connect-hudi/style/rmq_checkstyle.xml	86
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/config/IotdbConfig.java	80
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/config/IotdbConstant.java	9
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/config/SchemaProcessor.java	39
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceConnector.java	62
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceTask.java	101
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/exception/IotdbRuntimeException.java	7
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source/DeviceEntity.java	63
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source/IotdbQuery.java	85
connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source/IotdbReplicator.java	34
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/AbstractJdbcRecordBinder.java	111
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/DefaultJdbcRecordBinder.java	170
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/JdbcRecordBinder.java	6
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DebeziumTimeTypes.java	67
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/HeaderField.java	5
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java	19
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java	68
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/CachedConnectionProvider.java	89
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/ConnectionProvider.java	9
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/DefaultColumnConverter.java	366
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/JdbcColumnConverter.java	10
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java	230
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectFactory.java	7
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectLoader.java	87
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java	828
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/mysql/MySqlDatabaseDialect.java	87
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/mysql/MysqlDatabaseDialectFactory.java	15
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/openmldb/OpenMLDBDatabaseDialect.java	96
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/openmldb/OpenMLDBDatabaseDialectFactory.java	15
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/exception/ConfigException.java	13
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/exception/TableAlterOrCreateException.java	10
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java	163
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java	72
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinition.java	88
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java	45
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java	113
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java	148
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/DbStructure.java	221
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConfig.java	166
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConnector.java	36
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkTask.java	78
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcWriter.java	80
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java	68
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java	244
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SchemaPair.java	38
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java	59
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConfig.java	178
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConnector.java	55
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceTask.java	250
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceTaskConfig.java	15
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingCriteria.java	226
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/ColumnMapping.java	52
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/IncrementContext.java	63
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/QueryContext.java	73
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/QueryMode.java	5
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/SchemaMapping.java	63
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/TableLoadMode.java	25
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/SourceOffsetCompute.java	261
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java	78
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/BulkQuerier.java	100
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/Querier.java	97
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/TimestampIncrementingQuerier.java	192
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/BytesUtil.java	12
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ColumnDefAdjuster.java	48
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ConnectorGroupUtils.java	27
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/DateTimeUtils.java	44
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java	266
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/IdentifierRules.java	93
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcDriverInfo.java	63
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcUrlInfo.java	6
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/NumericMapping.java	29
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/QuoteMethod.java	21
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/TableType.java	40
connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java	127
connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java	5
connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java	36
connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java	34
connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java	153
connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java	61
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java	24
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaRocketmqConnector.java	119
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaRocketmqSinkConnector.java	31
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaRocketmqSinkTask.java	116
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaRocketmqSourceConnector.java	31
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaRocketmqSourceTask.java	97
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaRocketmqTask.java	79
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/RocketmqKafkaConnectorContext.java	16
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/RocketmqKafkaSinkTaskContext.java	92
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector/RocketmqKafkaSourceTaskContext.java	51
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util/AssignEncodedPartitionRocketmqRecordPartitionKafkaTopicPartitionMapper.java	38
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util/ConfigUtil.java	37
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util/EncodedPartitionRocketmqRecordPartitionKafkaTopicPartitionMapper.java	49
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util/EncodedTopicRocketmqBrokerNameKafkaTopicPartitionMapper.java	39
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util/KafkaPluginsUtil.java	19
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util/RecordUtil.java	115
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util/RegexEncodedPartitionRocketmqRecordPartitionKafkaTopicPartitionMapper.java	42
connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util/RocketmqRecordPartitionKafkaTopicPartitionMapper.java	45
connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java	39
connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java	46
connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java	69
connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java	201
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java	212
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java	35
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java	67
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java	104
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java	31
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java	122
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java	23
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java	103
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java	49
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java	52
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java	74
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java	52
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java	56
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java	84
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java	88
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java	26
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java	39
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java	116
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/config/ConnectorConfig.java	80
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/config/SinkConnectorConfig.java	63
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/config/SourceConnectorConfig.java	64
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/connector/MqttSinkConnector.java	32
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/connector/MqttSinkTask.java	59
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/connector/MqttSourceConnector.java	32
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/connector/MqttSourceTask.java	98
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/sink/Updater.java	111
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/source/Replicator.java	76
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/util/ConfigUtil.java	46
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/util/HmacSHA1Util.java	23
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/util/MqttConnectionUtil.java	18
connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/util/Utils.java	9
connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java	5
connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java	16
connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java	15
connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java	20
connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java	22
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java	155
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java	88
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java	23
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java	7
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java	32
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java	116
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java	7
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java	114
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java	31
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java	101
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java	12
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java	52
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java	18
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java	87
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java	148
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java	22
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java	25
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java	18
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java	18
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java	18
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java	27
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java	18
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java	5
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java	26
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java	22
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java	18
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java	19
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java	34
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java	18
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java	25
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java	22
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java	62
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java	10
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java	20
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java	45
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java	18
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java	17
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java	24
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java	26
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java	115
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java	32
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java	360
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java	15
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java	90
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java	14
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java	4
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java	21
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java	33
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java	42
connectors/rocketmq-connect-redis/style/copyright/Apache.xml	6
connectors/rocketmq-connect-redis/style/copyright/profiles_settings.xml	47
connectors/rocketmq-connect-redis/style/rmq_checkstyle.xml	85
connectors/rocketmq-connect-redis/style/rmq_codeStyle.xml	126
connectors/rocketmq-connect-sftp/src/main/java/org/apache/rocketmq/connect/http/sink/SftpClient.java	48
connectors/rocketmq-connect-sftp/src/main/java/org/apache/rocketmq/connect/http/sink/SftpConstant.java	13
connectors/rocketmq-connect-sftp/src/main/java/org/apache/rocketmq/connect/http/sink/SftpSinkConnector.java	36
connectors/rocketmq-connect-sftp/src/main/java/org/apache/rocketmq/connect/http/sink/SftpSinkTask.java	72
connectors/rocketmq-connect-sftp/src/main/java/org/apache/rocketmq/connect/http/sink/SftpSourceConnector.java	33
connectors/rocketmq-connect-sftp/src/main/java/org/apache/rocketmq/connect/http/sink/SftpSourceTask.java	117
connectors/rocketmq-replicator/package.xml	40
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/MetaSourceTask.java	96
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointConnector.java	151
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointTask.java	247
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatConnector.java	69
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatTask.java	213
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java	251
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceTask.java	647
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqConstants.java	14
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java	215
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java	245
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java	209
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/ConstDefine.java	7
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/LoggerName.java	6
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java	180
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigDefine.java	33
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigUtil.java	46
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConsumeFromWhere.java	6
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/DataType.java	8
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/FailoverStrategy.java	5
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java	522
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java	121
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java	90
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfigEnum.java	27
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskDivideConfig.java	70
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java	15
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/context/UnAckMessage.java	38
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/exception/GetMetaDataException.java	12
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/exception/InitMQClientException.java	12
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/exception/ParamInvalidException.java	9
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/exception/StartTaskException.java	12
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSync.java	46
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSyncStore.java	64
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/schema/FieldName.java	12
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/schema/SchemaEnum.java	5
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/stats/TpsLimiter.java	57
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideStrategyEnum.java	5
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByConsistentHash.java	63
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByQueue.java	48
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByTopic.java	40
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/TaskDivideStrategy.java	10
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java	95