apache / rocketmq-connect
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
3% | 10% | 20% | 24% | 41%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java3% | 10% | 20% | 24% | 41%
xml0% | 0% | 0% | 37% | 62%
py0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
avsc0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
schema-converter44% | 19% | 0% | 14% | 20%
rocketmq-connect-runtime0% | 17% | 27% | 22% | 31%
connectors0% | 6% | 20% | 26% | 46%
rocketmq-connect-sample0% | 0% | 45% | 0% | 54%
transforms0% | 0% | 0% | 37% | 62%
rocketmq-connect-cli0% | 0% | 0% | 25% | 74%
metric-exporter0% | 0% | 0% | 29% | 70%
style0% | 0% | 0% | 46% | 53%
distribution0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
AvroData.java
in schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro
 2028 68
JsonSchemaData.java
in schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json
 901 13
GenericDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 828 42
Worker.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 739 44
WorkerSinkTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 671 36
JsonConverter.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json
 664 20
ReplicatorSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 647 22
WorkerSourceTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 578 33
ReplicatorConnectorConfig.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config
 522 104
AbstractConfigManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 433 30
ConnectUtil.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 398 24
WorkerConfig.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config
 381 91
DefaultColumnConverter.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter
 366 8
DefaultRedisEventProcessor.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor
 360 8
DelegatingClassLoader.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation
 358 19
KafkaSinkSchemaConverter.java
in connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema
 297 5
BrokerBasedLog.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync
 296 17
RocketMQSourceSchemaConverter.java
in connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema
 295 5
User.java
in connectors/rocketmq-connect-deltalake/src/main/java/example/avro
 287 37
WorkerConnector.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 286 24
AbstractStateManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 285 22
RocketMqDatabaseHistory.java
in connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium
 269 10
ConnectStatsService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats
 267 22
ExpressionBuilder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util
 266 40
PluginUtils.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation
 263 12
SourceOffsetCompute.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset
 261 5
RestHandler.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest
 260 17
WorkerTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 253 31
ReplicatorSourceConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 251 13
JdbcSourceTask.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 250 11
ExpressionBuilder.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util
 247 36
DorisSinkConfig.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector
 247 23
ReplicatorCheckpointTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 247 12
RmqSourceReplicator.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 245 13
FieldsMetadata.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata
 244 7
FieldsMetadata.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata
 244 7
ConnectStatsManager.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats
 243 36
DatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 230 16
TimestampIncrementingCriteria.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 226 17
Updater.java
in connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink
 222 9
DbStructure.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 221 7
AbstractConnectController.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller
 219 24
Plugin.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation
 219 16
RmqMetaReplicator.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 215 15
ReplicatorHeartbeatTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 213 9
SourceTaskConfig.java
in connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo
 212 47
FileSourceTask.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 212 4
RmqSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 209 10
OkHttpUtils.java
in connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common
 205 16
KafkaSourceTask.java
in connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector
 201 11
Files With Most Units (Top 50)
File# lines# units
ReplicatorConnectorConfig.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config
 522 104
WorkerConfig.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config
 381 91
AvroData.java
in schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro
 2028 68
SourceTaskConfig.java
in connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo
 212 47
Config.java
in connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config
 199 45
Worker.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 739 44
GenericDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 828 42
ExpressionBuilder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util
 266 40
User.java
in connectors/rocketmq-connect-deltalake/src/main/java/example/avro
 287 37
ExpressionBuilder.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util
 247 36
WorkerSinkTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 671 36
ConnectStatsManager.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats
 243 36
WorkerSourceTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 578 33
WorkerTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 253 31
AbstractConfigManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 433 30
ConnectKeyValue.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common
 145 28
Config.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common
 155 26
ConnectorStateInfo.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities
 113 26
TaskConfig.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config
 90 25
ReplicationEvent.java
in connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event
 116 25
WorkerConnector.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 286 24
ConnectUtil.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 398 24
AbstractConnectController.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller
 219 24
DorisSinkConfig.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector
 247 23
JdbcSourceConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 178 23
ColumnDefinition.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column
 163 23
HudiConnectConfig.java
in connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config
 114 22
ReplicatorSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 647 22
AbstractStateManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 285 22
ConnectStatsService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats
 267 22
ColumnDefinition.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column
 149 21
DeltalakeConnectConfig.java
in connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/config
 86 21
WorkerDirectTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 198 21
RecordOffsetManagement.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 179 21
DefaultRedisRdbParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 148 20
Config.java
in connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms
 127 20
RmqConnectorConfig.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config
 121 20
JsonConverter.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json
 664 20
SinkConnectConfig.java
in connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config
 115 19
TaskDivideConfig.java
in connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config
 78 19
DelegatingClassLoader.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation
 358 19
RetryWithToleranceOperator.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors
 200 19
BaseTransformation.java
in transforms/src/main/java/org/apache/rocketmq/connect/transforms
 136 19
ConnectKeyValue.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom
 101 19
DbConnectorConfig.java
in connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config
 70 18
Config.java
in connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq
 117 18
QueryContext.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 73 18
JdbcSinkConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 166 18
Serdes.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization
 105 18
ProcessingContext.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors
 115 18
Files With Long Lines (Top 50)

There are 190 files with lines longer than 120 characters. In total, there are 666 long lines.

File# lines# units# long lines
ReplicatorSourceConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 251 13 26
Worker.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 739 44 26
ConnectStatsManager.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats
 243 36 26
ReplicatorSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 647 22 23
ReplicatorCheckpointTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 247 12 21
WorkerSinkTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 671 36 21
WorkerSourceTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 578 33 19
JsonConverter.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json
 664 20 15
ReplicatorCheckpointConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 151 8 13
ConnectUtil.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 398 24 11
KafkaRocketmqTask.java
in connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector
 79 7 10
ReplicatorHeartbeatTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 213 9 10
RmqMetaReplicator.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 215 15 9
WorkerSinkTaskContext.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 178 13 9
RecordUtil.java
in connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/util
 115 4 8
Updater.java
in connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink
 222 9 8
MySqlReadOnlyIncrementalSnapshotChangeEventSource.java
in connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql
 166 17 8
ConnectMetricsTemplates.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics
 128 12 8
BrokerBasedLog.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync
 296 17 8
AbstractConfigManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 433 30 8
AbstractPositionManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 190 17 8
AbstractLocalSchemaRegistryClient.java
in schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common
 136 9 8
AvroData.java
in schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro
 2028 68 8
KafkaRocketmqConnector.java
in connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector
 119 7 7
KafkaRocketmqSinkTask.java
in connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector
 116 5 7
BufferedRecords.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 148 7 7
ServiceProviderUtil.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 100 4 7
RocketMqDatabaseHistory.java
in connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium
 269 10 6
JdbcSourceTask.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 250 11 6
RestHandler.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest
 260 17 6
FcSinkTask.java
in connectors/aliyun/rocketmq-connect-fc/src/main/java/org/apache/rocketmq/connect/fc/sink
 101 7 5
HudiSinkConnector.java
in connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector
 66 6 5
KafkaSourceTask.java
in connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector
 201 11 5
InitSync.java
in connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync
 122 6 5
GenericDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 828 42 5
WorkerTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 253 31 5
ErrorMetricsGroup.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors
 65 9 5
FileSourceTask.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 212 4 5
KafkaRocketmqSourceTask.java
in connectors/rocketmq-connect-kafka-connector-adapter/src/main/java/org/apache/rocketmq/connect/kafka/connector
 97 5 4
DorisStreamLoader.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink
 83 7 4
Querier.java
in connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source
 138 8 4
MySqlReadOnlyIncrementalSnapshotContext.java
in connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql
 120 16 4
DeltalakeWriterOnHdfs.java
in connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/writer
 186 6 4
Utils.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common
 180 13 4
ElasticsearchQuery.java
in connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/replicator/source
 129 5 4
ElasticsearchSinkTask.java
in connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector
 176 6 4
DelegatingClassLoader.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation
 358 19 4
DeadLetterQueueReporter.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors
 162 4 4
WorkerErrorRecordReporter.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors
 40 2 4
JsonSchemaData.java
in schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json
 901 13 4
Correlations

File Size vs. Commits (all time): 793 points

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointConnector.java x: 5 commits (all time) y: 151 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointTask.java x: 6 commits (all time) y: 247 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatConnector.java x: 4 commits (all time) y: 69 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatTask.java x: 3 commits (all time) y: 213 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java x: 8 commits (all time) y: 251 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceTask.java x: 13 commits (all time) y: 647 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/LoggerName.java x: 1 commits (all time) y: 6 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java x: 7 commits (all time) y: 522 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java x: 4 commits (all time) y: 95 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java x: 10 commits (all time) y: 433 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceImpl.java x: 17 commits (all time) y: 73 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/AbstractJdbcRecordBinder.java x: 1 commits (all time) y: 111 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/DefaultJdbcRecordBinder.java x: 1 commits (all time) y: 170 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/HeaderField.java x: 2 commits (all time) y: 5 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java x: 3 commits (all time) y: 19 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java x: 5 commits (all time) y: 68 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/CachedConnectionProvider.java x: 1 commits (all time) y: 89 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/ConnectionProvider.java x: 1 commits (all time) y: 9 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/DefaultColumnConverter.java x: 1 commits (all time) y: 366 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java x: 4 commits (all time) y: 230 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectFactory.java x: 4 commits (all time) y: 7 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectLoader.java x: 1 commits (all time) y: 87 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java x: 1 commits (all time) y: 828 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/openmldb/OpenMLDBDatabaseDialect.java x: 1 commits (all time) y: 96 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/exception/ConfigException.java x: 3 commits (all time) y: 13 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java x: 3 commits (all time) y: 163 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java x: 3 commits (all time) y: 72 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinition.java x: 3 commits (all time) y: 88 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java x: 3 commits (all time) y: 45 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java x: 3 commits (all time) y: 113 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/DbStructure.java x: 1 commits (all time) y: 221 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConfig.java x: 1 commits (all time) y: 166 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConnector.java x: 1 commits (all time) y: 36 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkTask.java x: 1 commits (all time) y: 78 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java x: 2 commits (all time) y: 68 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java x: 4 commits (all time) y: 244 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SchemaPair.java x: 4 commits (all time) y: 38 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java x: 3 commits (all time) y: 59 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConfig.java x: 1 commits (all time) y: 178 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConnector.java x: 1 commits (all time) y: 55 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceTask.java x: 1 commits (all time) y: 250 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/IncrementContext.java x: 1 commits (all time) y: 63 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/TableLoadMode.java x: 1 commits (all time) y: 25 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/SourceOffsetCompute.java x: 5 commits (all time) y: 261 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java x: 4 commits (all time) y: 78 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/BulkQuerier.java x: 4 commits (all time) y: 100 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/TimestampIncrementingQuerier.java x: 4 commits (all time) y: 192 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/BytesUtil.java x: 4 commits (all time) y: 12 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ConnectorGroupUtils.java x: 3 commits (all time) y: 27 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java x: 3 commits (all time) y: 266 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/NumericMapping.java x: 4 commits (all time) y: 29 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java x: 45 commits (all time) y: 578 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/FileAndPropertyUtil.java x: 5 commits (all time) y: 104 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java x: 52 commits (all time) y: 739 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java x: 7 commits (all time) y: 381 lines of code metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/reporter/RocketMQClientUtil.java x: 2 commits (all time) y: 122 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java x: 21 commits (all time) y: 398 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java x: 5 commits (all time) y: 245 lines of code rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java x: 12 commits (all time) y: 212 lines of code rocketmq-connect-runtime/src/main/resources/package.xml x: 6 commits (all time) y: 24 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTaskContext.java x: 7 commits (all time) y: 178 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTaskContext.java x: 2 commits (all time) y: 33 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginUtils.java x: 7 commits (all time) y: 263 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginWrapper.java x: 4 commits (all time) y: 81 lines of code rocketmq-connect-runtime/src/main/resources/logback.xml x: 6 commits (all time) y: 174 lines of code schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java x: 2 commits (all time) y: 2028 lines of code metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/MetricName.java x: 1 commits (all time) y: 65 lines of code metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/stats/CumulativeCount.java x: 1 commits (all time) y: 23 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/DistributedConnectStartup.java x: 11 commits (all time) y: 158 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/RecordOffsetManagement.java x: 3 commits (all time) y: 179 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TargetState.java x: 3 commits (all time) y: 5 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnector.java x: 8 commits (all time) y: 286 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/AbstractConnectController.java x: 8 commits (all time) y: 219 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractPositionManagementService.java x: 1 commits (all time) y: 190 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractStateManagementService.java x: 1 commits (all time) y: 285 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementService.java x: 10 commits (all time) y: 17 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementServiceImpl.java x: 14 commits (all time) y: 124 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java x: 14 commits (all time) y: 29 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/PositionManagementService.java x: 10 commits (all time) y: 27 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementService.java x: 5 commits (all time) y: 23 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalConfigManagementServiceImpl.java x: 1 commits (all time) y: 113 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalStateManagementServiceImpl.java x: 1 commits (all time) y: 132 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/FilePositionManagementServiceImpl.java x: 7 commits (all time) y: 140 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryClusterManagementServiceImpl.java x: 5 commits (all time) y: 40 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java x: 14 commits (all time) y: 141 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/RetryUtil.java x: 1 commits (all time) y: 123 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLog.java x: 14 commits (all time) y: 296 lines of code connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/signal/RocketMqSignalThread.java x: 2 commits (all time) y: 175 lines of code connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/Converters.java x: 5 commits (all time) y: 126 lines of code connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java x: 2 commits (all time) y: 205 lines of code connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnector.java x: 2 commits (all time) y: 50 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/DelegatingClassLoader.java x: 5 commits (all time) y: 358 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java x: 23 commits (all time) y: 260 lines of code connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/HttpSinkTask.java x: 3 commits (all time) y: 33 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java x: 38 commits (all time) y: 671 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/ConnectorConfig.java x: 6 commits (all time) y: 58 lines of code connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/util/ConfigUtil.java x: 1 commits (all time) y: 46 lines of code connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConfig.java x: 2 commits (all time) y: 110 lines of code connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConstant.java x: 2 commits (all time) y: 14 lines of code connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/replicator/source/ElasticsearchQuery.java x: 3 commits (all time) y: 129 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/Plugin.java x: 7 commits (all time) y: 219 lines of code schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde/AvroDatumReaderFactory.java x: 1 commits (all time) y: 145 lines of code schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json/JsonSchemaData.java x: 1 commits (all time) y: 901 lines of code schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/AbstractLocalSchemaRegistryClient.java x: 1 commits (all time) y: 136 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java x: 21 commits (all time) y: 198 lines of code connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java x: 3 commits (all time) y: 127 lines of code connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java x: 3 commits (all time) y: 153 lines of code connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java x: 2 commits (all time) y: 16 lines of code connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector/DorisSinkConfig.java x: 1 commits (all time) y: 247 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java x: 2 commits (all time) y: 199 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java x: 2 commits (all time) y: 46 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java x: 2 commits (all time) y: 177 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java x: 2 commits (all time) y: 79 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnector.java x: 2 commits (all time) y: 62 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java x: 2 commits (all time) y: 167 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java x: 2 commits (all time) y: 86 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java x: 2 commits (all time) y: 138 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideTaskByTopic.java x: 2 commits (all time) y: 94 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/MetricGroup.java x: 2 commits (all time) y: 30 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/FileBaseKeyValueStore.java x: 5 commits (all time) y: 90 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java x: 7 commits (all time) y: 145 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/SinkConnectorConfig.java x: 4 commits (all time) y: 52 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TransformChain.java x: 16 commits (all time) y: 107 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/distributed/DistributedConnectController.java x: 6 commits (all time) y: 74 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginClassLoader.java x: 3 commits (all time) y: 50 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/standalone/StandaloneConnectController.java x: 5 commits (all time) y: 38 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json/JsonConverter.java x: 4 commits (all time) y: 664 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/RetryWithToleranceOperator.java x: 3 commits (all time) y: 200 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/WorkerErrorRecordReporter.java x: 4 commits (all time) y: 40 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/ConnectorStateInfo.java x: 2 commits (all time) y: 113 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/JsonDeserializer.java x: 5 commits (all time) y: 30 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/DefaultConnectorContext.java x: 7 commits (all time) y: 40 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceService.java x: 9 commits (all time) y: 51 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/DefaultAllocateConnAndTaskStrategy.java x: 7 commits (all time) y: 60 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java x: 2 commits (all time) y: 267 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/ClusterConfigState.java x: 2 commits (all time) y: 98 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageReaderImpl.java x: 6 commits (all time) y: 33 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageWriter.java x: 4 commits (all time) y: 106 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/TransferUtils.java x: 3 commits (all time) y: 84 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Utils.java x: 6 commits (all time) y: 99 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java x: 7 commits (all time) y: 209 lines of code connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java x: 2 commits (all time) y: 212 lines of code connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java x: 2 commits (all time) y: 149 lines of code connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java x: 2 commits (all time) y: 155 lines of code connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java x: 2 commits (all time) y: 360 lines of code connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java x: 3 commits (all time) y: 71 lines of code connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java x: 3 commits (all time) y: 222 lines of code connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/KafkaSinkValueConverter.java x: 3 commits (all time) y: 97 lines of code connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/KafkaSinkSchemaConverter.java x: 3 commits (all time) y: 297 lines of code connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/RocketMQSourceSchemaConverter.java x: 3 commits (all time) y: 295 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java x: 4 commits (all time) y: 215 lines of code rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSinkTask.java x: 12 commits (all time) y: 61 lines of code connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkConnector.java x: 9 commits (all time) y: 68 lines of code connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkTask.java x: 7 commits (all time) y: 112 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java x: 4 commits (all time) y: 180 lines of code connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java x: 1 commits (all time) y: 200 lines of code
2028.0
lines of code
  min: 1.0
  average: 68.73
  25th percentile: 16.0
  median: 37.0
  75th percentile: 84.0
  max: 2028.0
0 52.0
commits (all time)
min: 1.0 | average: 2.26 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 52.0

File Size vs. Contributors (all time): 793 points

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointConnector.java x: 2 contributors (all time) y: 151 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointTask.java x: 2 contributors (all time) y: 247 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatConnector.java x: 3 contributors (all time) y: 69 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatTask.java x: 3 contributors (all time) y: 213 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java x: 4 contributors (all time) y: 251 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceTask.java x: 4 contributors (all time) y: 647 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/LoggerName.java x: 1 contributors (all time) y: 6 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java x: 4 contributors (all time) y: 522 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java x: 2 contributors (all time) y: 95 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java x: 4 contributors (all time) y: 433 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceImpl.java x: 9 contributors (all time) y: 73 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/AbstractJdbcRecordBinder.java x: 1 contributors (all time) y: 111 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/DefaultJdbcRecordBinder.java x: 1 contributors (all time) y: 170 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DebeziumTimeTypes.java x: 2 contributors (all time) y: 67 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java x: 1 contributors (all time) y: 19 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java x: 1 contributors (all time) y: 68 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/CachedConnectionProvider.java x: 1 contributors (all time) y: 89 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/ConnectionProvider.java x: 1 contributors (all time) y: 9 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/DefaultColumnConverter.java x: 1 contributors (all time) y: 366 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java x: 1 contributors (all time) y: 230 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectLoader.java x: 1 contributors (all time) y: 87 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java x: 1 contributors (all time) y: 828 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/openmldb/OpenMLDBDatabaseDialect.java x: 1 contributors (all time) y: 96 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java x: 1 contributors (all time) y: 163 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java x: 1 contributors (all time) y: 72 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java x: 1 contributors (all time) y: 45 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java x: 1 contributors (all time) y: 113 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java x: 1 contributors (all time) y: 148 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/DbStructure.java x: 1 contributors (all time) y: 221 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConnector.java x: 1 contributors (all time) y: 36 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java x: 1 contributors (all time) y: 244 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java x: 1 contributors (all time) y: 59 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConfig.java x: 1 contributors (all time) y: 178 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConnector.java x: 1 contributors (all time) y: 55 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceTask.java x: 1 contributors (all time) y: 250 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/TableLoadMode.java x: 1 contributors (all time) y: 25 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/SourceOffsetCompute.java x: 1 contributors (all time) y: 261 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java x: 2 contributors (all time) y: 78 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/TimestampIncrementingQuerier.java x: 1 contributors (all time) y: 192 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java x: 1 contributors (all time) y: 266 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java x: 14 contributors (all time) y: 578 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/FileAndPropertyUtil.java x: 2 contributors (all time) y: 104 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java x: 13 contributors (all time) y: 739 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java x: 4 contributors (all time) y: 381 lines of code metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/reporter/RocketMQClientUtil.java x: 2 contributors (all time) y: 122 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java x: 9 contributors (all time) y: 398 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java x: 5 contributors (all time) y: 245 lines of code rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java x: 8 contributors (all time) y: 212 lines of code rocketmq-connect-cli/src/main/resources/package.xml x: 2 contributors (all time) y: 24 lines of code rocketmq-connect-runtime/src/main/resources/package.xml x: 4 contributors (all time) y: 24 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTaskContext.java x: 2 contributors (all time) y: 178 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTaskContext.java x: 2 contributors (all time) y: 33 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginUtils.java x: 2 contributors (all time) y: 263 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginWrapper.java x: 2 contributors (all time) y: 81 lines of code rocketmq-connect-runtime/src/main/resources/logback.xml x: 2 contributors (all time) y: 174 lines of code schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java x: 2 contributors (all time) y: 2028 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/DistributedConnectStartup.java x: 3 contributors (all time) y: 158 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnector.java x: 3 contributors (all time) y: 286 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/AbstractConnectController.java x: 2 contributors (all time) y: 219 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractPositionManagementService.java x: 1 contributors (all time) y: 190 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractStateManagementService.java x: 1 contributors (all time) y: 285 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementService.java x: 4 contributors (all time) y: 17 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementServiceImpl.java x: 7 contributors (all time) y: 124 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java x: 6 contributors (all time) y: 29 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalStateManagementServiceImpl.java x: 1 contributors (all time) y: 132 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/FilePositionManagementServiceImpl.java x: 3 contributors (all time) y: 140 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryClusterManagementServiceImpl.java x: 2 contributors (all time) y: 40 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java x: 4 contributors (all time) y: 141 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/RetryUtil.java x: 1 contributors (all time) y: 123 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ServiceProviderUtil.java x: 2 contributors (all time) y: 100 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLog.java x: 8 contributors (all time) y: 296 lines of code connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java x: 2 contributors (all time) y: 205 lines of code connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnector.java x: 2 contributors (all time) y: 50 lines of code connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkTask.java x: 3 contributors (all time) y: 63 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/DelegatingClassLoader.java x: 3 contributors (all time) y: 358 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java x: 11 contributors (all time) y: 260 lines of code connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/HttpSinkTask.java x: 3 contributors (all time) y: 33 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java x: 13 contributors (all time) y: 671 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsManager.java x: 4 contributors (all time) y: 243 lines of code schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json/JsonSchemaData.java x: 1 contributors (all time) y: 901 lines of code schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/AbstractLocalSchemaRegistryClient.java x: 1 contributors (all time) y: 136 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java x: 9 contributors (all time) y: 198 lines of code connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java x: 2 contributors (all time) y: 153 lines of code connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java x: 2 contributors (all time) y: 61 lines of code connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java x: 2 contributors (all time) y: 16 lines of code connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java x: 2 contributors (all time) y: 15 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java x: 2 contributors (all time) y: 199 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java x: 2 contributors (all time) y: 167 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java x: 2 contributors (all time) y: 138 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/FileBaseKeyValueStore.java x: 4 contributors (all time) y: 90 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java x: 3 contributors (all time) y: 145 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TransformChain.java x: 5 contributors (all time) y: 107 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json/JsonConverter.java x: 2 contributors (all time) y: 664 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/RetryWithToleranceOperator.java x: 1 contributors (all time) y: 200 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/DefaultConnectorContext.java x: 3 contributors (all time) y: 40 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceService.java x: 6 contributors (all time) y: 51 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategy.java x: 3 contributors (all time) y: 9 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategyByConsistentHash.java x: 3 contributors (all time) y: 74 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/DefaultAllocateConnAndTaskStrategy.java x: 4 contributors (all time) y: 60 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java x: 2 contributors (all time) y: 267 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/MemoryBasedKeyValueStore.java x: 3 contributors (all time) y: 48 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/DataSynchronizerCallback.java x: 2 contributors (all time) y: 4 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java x: 5 contributors (all time) y: 209 lines of code connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java x: 2 contributors (all time) y: 212 lines of code connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java x: 2 contributors (all time) y: 116 lines of code connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java x: 2 contributors (all time) y: 360 lines of code rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FilterTransform.java x: 3 contributors (all time) y: 25 lines of code connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/KafkaSinkSchemaConverter.java x: 1 contributors (all time) y: 297 lines of code connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/RocketMQSourceSchemaConverter.java x: 1 contributors (all time) y: 295 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/MetaSourceTask.java x: 4 contributors (all time) y: 96 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java x: 4 contributors (all time) y: 215 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java x: 3 contributors (all time) y: 180 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java x: 3 contributors (all time) y: 121 lines of code style/rmq_checkstyle.xml x: 3 contributors (all time) y: 91 lines of code
2028.0
lines of code
  min: 1.0
  average: 68.73
  25th percentile: 16.0
  median: 37.0
  75th percentile: 84.0
  max: 2028.0
0 14.0
contributors (all time)
min: 1.0 | average: 1.5 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 14.0

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".

File Size vs. Commits (90 days): 75 points

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointConnector.java x: 1 commits (90d) y: 151 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointTask.java x: 1 commits (90d) y: 247 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatConnector.java x: 1 commits (90d) y: 69 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatTask.java x: 1 commits (90d) y: 213 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java x: 1 commits (90d) y: 251 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceTask.java x: 1 commits (90d) y: 647 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/LoggerName.java x: 1 commits (90d) y: 6 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java x: 1 commits (90d) y: 522 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java x: 1 commits (90d) y: 95 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java x: 2 commits (90d) y: 433 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceImpl.java x: 1 commits (90d) y: 73 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/AbstractJdbcRecordBinder.java x: 1 commits (90d) y: 111 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/DefaultJdbcRecordBinder.java x: 1 commits (90d) y: 170 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DebeziumTimeTypes.java x: 1 commits (90d) y: 67 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java x: 1 commits (90d) y: 19 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/CachedConnectionProvider.java x: 1 commits (90d) y: 89 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/ConnectionProvider.java x: 1 commits (90d) y: 9 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/DefaultColumnConverter.java x: 1 commits (90d) y: 366 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/JdbcColumnConverter.java x: 1 commits (90d) y: 10 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java x: 1 commits (90d) y: 230 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectLoader.java x: 1 commits (90d) y: 87 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java x: 1 commits (90d) y: 828 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/mysql/MysqlDatabaseDialectFactory.java x: 1 commits (90d) y: 15 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java x: 1 commits (90d) y: 163 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java x: 1 commits (90d) y: 45 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java x: 1 commits (90d) y: 148 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/DbStructure.java x: 1 commits (90d) y: 221 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConnector.java x: 1 commits (90d) y: 36 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkTask.java x: 1 commits (90d) y: 78 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcWriter.java x: 1 commits (90d) y: 80 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java x: 1 commits (90d) y: 244 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java x: 1 commits (90d) y: 59 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConfig.java x: 1 commits (90d) y: 178 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConnector.java x: 1 commits (90d) y: 55 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingCriteria.java x: 1 commits (90d) y: 226 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/ColumnMapping.java x: 1 commits (90d) y: 52 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/IncrementContext.java x: 1 commits (90d) y: 63 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/TableLoadMode.java x: 1 commits (90d) y: 25 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/SourceOffsetCompute.java x: 1 commits (90d) y: 261 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/BulkQuerier.java x: 1 commits (90d) y: 100 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/TimestampIncrementingQuerier.java x: 1 commits (90d) y: 192 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ColumnDefAdjuster.java x: 1 commits (90d) y: 48 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ConnectorGroupUtils.java x: 1 commits (90d) y: 27 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java x: 1 commits (90d) y: 266 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/IdentifierRules.java x: 1 commits (90d) y: 93 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/QuoteMethod.java x: 1 commits (90d) y: 21 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/TableType.java x: 1 commits (90d) y: 40 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java x: 1 commits (90d) y: 578 lines of code
828.0
lines of code
  min: 5.0
  average: 127.92
  25th percentile: 29.0
  median: 73.0
  75th percentile: 170.0
  max: 828.0
0 2.0
commits (90d)
min: 1.0 | average: 1.01 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0

File Size vs. Contributors (90 days): 75 points

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointConnector.java x: 1 contributors (90d) y: 151 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointTask.java x: 1 contributors (90d) y: 247 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatConnector.java x: 1 contributors (90d) y: 69 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatTask.java x: 1 contributors (90d) y: 213 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java x: 1 contributors (90d) y: 251 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceTask.java x: 1 contributors (90d) y: 647 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/LoggerName.java x: 1 contributors (90d) y: 6 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java x: 1 contributors (90d) y: 522 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java x: 1 contributors (90d) y: 95 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java x: 2 contributors (90d) y: 433 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceImpl.java x: 1 contributors (90d) y: 73 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/AbstractJdbcRecordBinder.java x: 1 contributors (90d) y: 111 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/DefaultJdbcRecordBinder.java x: 1 contributors (90d) y: 170 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DebeziumTimeTypes.java x: 1 contributors (90d) y: 67 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java x: 1 contributors (90d) y: 19 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/CachedConnectionProvider.java x: 1 contributors (90d) y: 89 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/ConnectionProvider.java x: 1 contributors (90d) y: 9 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/DefaultColumnConverter.java x: 1 contributors (90d) y: 366 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/JdbcColumnConverter.java x: 1 contributors (90d) y: 10 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java x: 1 contributors (90d) y: 230 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectLoader.java x: 1 contributors (90d) y: 87 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java x: 1 contributors (90d) y: 828 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/mysql/MysqlDatabaseDialectFactory.java x: 1 contributors (90d) y: 15 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java x: 1 contributors (90d) y: 163 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java x: 1 contributors (90d) y: 45 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java x: 1 contributors (90d) y: 148 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/DbStructure.java x: 1 contributors (90d) y: 221 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConnector.java x: 1 contributors (90d) y: 36 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkTask.java x: 1 contributors (90d) y: 78 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcWriter.java x: 1 contributors (90d) y: 80 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java x: 1 contributors (90d) y: 244 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java x: 1 contributors (90d) y: 59 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConfig.java x: 1 contributors (90d) y: 178 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConnector.java x: 1 contributors (90d) y: 55 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingCriteria.java x: 1 contributors (90d) y: 226 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/ColumnMapping.java x: 1 contributors (90d) y: 52 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/IncrementContext.java x: 1 contributors (90d) y: 63 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/TableLoadMode.java x: 1 contributors (90d) y: 25 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/SourceOffsetCompute.java x: 1 contributors (90d) y: 261 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/BulkQuerier.java x: 1 contributors (90d) y: 100 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/TimestampIncrementingQuerier.java x: 1 contributors (90d) y: 192 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ColumnDefAdjuster.java x: 1 contributors (90d) y: 48 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ConnectorGroupUtils.java x: 1 contributors (90d) y: 27 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java x: 1 contributors (90d) y: 266 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/IdentifierRules.java x: 1 contributors (90d) y: 93 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/QuoteMethod.java x: 1 contributors (90d) y: 21 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/TableType.java x: 1 contributors (90d) y: 40 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java x: 1 contributors (90d) y: 578 lines of code
828.0
lines of code
  min: 5.0
  average: 127.92
  25th percentile: 29.0
  median: 73.0
  75th percentile: 170.0
  max: 828.0
0 2.0
contributors (90d)
min: 1.0 | average: 1.01 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0