apache / rocketmq-externals
File Size

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

Intro
Learn more...
File Size Overall
0% | 0% | 14% | 37% | 48%
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
scala0% | 0% | 45% | 31% | 22%
java0% | 0% | 9% | 35% | 54%
py0% | 0% | 100% | 0% | 0%
go0% | 0% | 0% | 52% | 47%
xml0% | 0% | 0% | 45% | 54%
yaml0% | 0% | 0% | 0% | 100%
yml0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
rocketmq-spark0% | 0% | 33% | 30% | 35%
rocketmq-jms0% | 0% | 15% | 50% | 33%
dev0% | 0% | 100% | 0% | 0%
rocketmq-logstash-integration0% | 0% | 60% | 39% | 0%
rocketmq-mysql0% | 0% | 14% | 8% | 77%
rocketmq-knative0% | 0% | 0% | 46% | 53%
rocketmq-iot-bridge0% | 0% | 0% | 37% | 62%
rocketmq-flume0% | 0% | 0% | 70% | 29%
logappender0% | 0% | 0% | 85% | 14%
rocketmq-hbase0% | 0% | 0% | 40% | 59%
rocketmq-redis0% | 0% | 0% | 38% | 61%
rocketmq-serializer0% | 0% | 0% | 18% | 81%
rocketmq-beats-integration0% | 0% | 0% | 59% | 40%
rocketmq-ansible0% | 0% | 0% | 0% | 100%
rocketmq-cloudevents-binding0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
MQPullInputDStream.scala
in rocketmq-spark/src/main/scala/org/apache/spark/streaming
 399 19
JmsBaseMessage.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message
 324 53
296 13
CachedRocketMQConsumer.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 267 15
RocketMQSource.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 249 8
RocketMQSourceProvider.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 218 14
RocketMQ.java
in rocketmq-logstash-integration/rocketmq-logstash-output/src/main/java/org/apache/rocketmq/logstashplugin/output
 216 12
EventProcessor.java
in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog
 204 13
JmsBaseSession.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 199 32
MessageUtil.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/common/util
 191 11
JmsBaseMessageProducer.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 186 20
rocketmqsource.go
in rocketmq-knative/source/pkg/reconciler
 184 12
JmsBytesMessage.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message
 175 31
RocketMQSink.java
in rocketmq-flume/rocketmq-flume-sink/src/main/java/org/apache/rocketmq/flume/ng/sink
 174 5
table.go
in rocketmq-knative/source/pkg/controller/testing
 173 10
RocketMQRedisReplicator.java
in rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator
 159 21
RocketMqRDD.scala
in rocketmq-spark/src/main/scala/org/apache/spark/streaming
 158 10
MqttIdleHandler.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler
 150 7
RocketmqLog4j2Appender.java
in logappender/src/main/java/org/apache/rocketmq/logappender/log4j2
 145 5
RocketMQSourceRDD.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 143 6
RocketMQ.java
in rocketmq-logstash-integration/rocketmq-logstash-input/src/main/java/org/apache/rocketmq/logstashplugin/input
 143 6
MessageConverter.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/util
 142 2
rocketmqsource.go
in rocketmq-knative/source/pkg/client/clientset/versioned/typed/sources/v1alpha1
 142 10
rmq_codeStyle.xml
in rocketmq-serializer/style
 140 -
rmq_codeStyle.xml
in rocketmq-spark/style
 140 -
rmq_codeStyle.xml
in rocketmq-jms/style
 140 -
RocketMqUtils.scala
in rocketmq-spark/src/main/scala/org/apache/rocketmq/spark
 134 8
RocketMQOffsetReader.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 133 10
reconciler.go
in rocketmq-knative/source/pkg/controller/sdk
 128 5
rmq_codeStyle.xml
in rocketmq-iot-bridge/style
 126 -
rmq_codeStyle.xml
in rocketmq-mysql/style
 126 -
rmq_codeStyle.xml
in rocketmq-hbase/style
 126 -
rmq_codeStyle.xml
in rocketmq-flume/style
 126 -
rmq_codeStyle.xml
in rocketmq-redis/style
 126 -
JmsBaseMessageConsumer.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 123 11
InMemorySubscriptionStore.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/storage/subscription/impl
 121 2
JmsBaseConnection.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 120 13
CachedMQConsumer.scala
in rocketmq-spark/src/main/scala/org/apache/rocketmq/spark
 119 6
factory.go
in rocketmq-knative/source/pkg/client/informers/externalversions
 117 10
Config.java
in rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source
 114 18
eventtype.go
in rocketmq-knative/source/pkg/reconciler/eventtype
 111 6
RocketMQSource.java
in rocketmq-flume/rocketmq-flume-source/src/main/java/org/apache/rocketmq/flume/ng/source
 109 3
Replicator.java
in rocketmq-hbase/rocketmq-hbase-sink/src/main/java/org/apache/rocketmq/hbase/sink
 107 6
RocketMQRelation.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 106 2
client.go
in rocketmq-beats-integration/libbeat/outputs/rocketmq
 105 5
rocketmqsource_types.go
in rocketmq-knative/source/pkg/apis/sources/v1alpha1
 105 14
adapter.go
in rocketmq-knative/source/pkg/adapter
 105 3
RocketMQConfig.java
in rocketmq-spark/src/main/java/org/apache/rocketmq/spark
 103 4
RocketmqLog4jAppender.java
in logappender/src/main/java/org/apache/rocketmq/logappender/log4j
 103 15
RocketmqLogbackAppender.java
in logappender/src/main/java/org/apache/rocketmq/logappender/logback
 101 12
Files With Most Units (Top 50)
File# lines# units
JmsBaseMessage.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message
 324 53
JmsBaseSession.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 199 32
JmsBytesMessage.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message
 175 31
CommonContext.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 86 23
RocketMQRedisReplicator.java
in rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator
 159 21
JmsBaseMessageProducer.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 186 20
MQPullInputDStream.scala
in rocketmq-spark/src/main/scala/org/apache/spark/streaming
 399 19
Config.java
in rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source
 114 18
SimpleMQPullConsumerProvider.java
in rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming
 72 15
CachedRocketMQConsumer.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 267 15
RocketmqLog4jAppender.java
in logappender/src/main/java/org/apache/rocketmq/logappender/log4j
 103 15
RocketMQSourceProvider.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 218 14
rocketmqsource_types.go
in rocketmq-knative/source/pkg/apis/sources/v1alpha1
 105 14
JmsBaseConnection.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 120 13
EventProcessor.java
in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog
 204 13
296 13
Message.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/common/data
 64 12
MessageSet.java
in rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming
 56 12
RMQPushConsumerExt.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 89 12
Config.java
in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql
 91 12
rocketmqsource.go
in rocketmq-knative/source/pkg/reconciler
 184 12
RocketMQ.java
in rocketmq-logstash-integration/rocketmq-logstash-output/src/main/java/org/apache/rocketmq/logstashplugin/output
 216 12
RocketmqLogbackAppender.java
in logappender/src/main/java/org/apache/rocketmq/logappender/logback
 101 12
MessageUtil.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/common/util
 191 11
JmsBaseMessageConsumer.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 123 11
RocketMqRDD.scala
in rocketmq-spark/src/main/scala/org/apache/spark/streaming
 158 10
RocketMQOffsetReader.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 133 10
zz_generated.deepcopy.go
in rocketmq-knative/source/pkg/apis/sources/v1alpha1
 77 10
table.go
in rocketmq-knative/source/pkg/controller/testing
 173 10
factory.go
in rocketmq-knative/source/pkg/client/informers/externalversions
 117 10
rocketmqsource.go
in rocketmq-knative/source/pkg/client/clientset/versioned/typed/sources/v1alpha1
 142 10
Messages.java
in rocketmq-serializer/rocketmq-serializer-core/src/main/java/org/apache/rocketmq/serializer
 48 9
JmsBaseConnectionMetaData.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 97 9
RocketMQMessageWriter.java
in rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl
 63 8
RocketMQSource.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 249 8
RocketMqUtils.scala
in rocketmq-spark/src/main/scala/org/apache/rocketmq/spark
 134 8
JmsBaseConnectionFactory.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 75 8
mock_client.go
in rocketmq-knative/source/pkg/controller/testing
 100 8
Configure.java
in rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/conf
 63 8
MqttIdleHandler.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler
 150 7
Subscription.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/data
 33 7
ReliableRocketMQReceiver.java
in rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming
 77 7
TopicQueueId.java
in rocketmq-spark/src/main/java/org/apache/rocketmq/spark
 63 7
BinlogPositionManager.java
in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/position
 100 7
Table.java
in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema
 32 7
Transaction.java
in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog
 55 7
KryoEventSerializer.java
in rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/mq
 73 7
Client.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/connection/client
 25 6
MqttConnectMessageHandler.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl
 63 6
MQTTBridge.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot
 92 6
Files With Long Lines (Top 50)

There are 56 files with lines longer than 120 characters. In total, there are 114 long lines.

File# lines# units# long lines
RocketMQ.java
in rocketmq-logstash-integration/rocketmq-logstash-input/src/main/java/org/apache/rocketmq/logstashplugin/input
 143 6 6
table.go
in rocketmq-knative/source/pkg/controller/testing
 173 10 5
factory.go
in rocketmq-knative/source/pkg/client/informers/externalversions
 117 10 5
rocketmqsource.go
in rocketmq-knative/source/pkg/client/informers/externalversions/sources/v1alpha1
 54 5 5
MessageUtil.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/common/util
 191 11 4
MQPullInputDStream.scala
in rocketmq-spark/src/main/scala/org/apache/spark/streaming
 399 19 4
RocketMqUtils.scala
in rocketmq-spark/src/main/scala/org/apache/rocketmq/spark
 134 8 4
eventtype.go
in rocketmq-knative/source/pkg/reconciler/eventtype
 111 6 4
InMemorySubscriptionStore.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/storage/subscription/impl
 121 2 3
MQTTBridge.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot
 92 6 3
ReliableRocketMQReceiver.java
in rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming
 77 7 3
RMQPushConsumerExt.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 89 12 3
reconciler.go
in rocketmq-knative/source/pkg/controller/sdk
 128 5 3
creds.go
in rocketmq-knative/source/pkg/reconciler
 37 2 3
interface.go
in rocketmq-knative/source/pkg/client/informers/externalversions/sources
 19 2 3
rocketmqsource.go
in rocketmq-knative/source/pkg/client/clientset/versioned/typed/sources/v1alpha1
 142 10 3
MqttConnectMessageHandler.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl
 63 6 2
RocketMQMessageFactory.java
in rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent
 39 3 2
RocketMQSourceProvider.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 218 14 2
CachedMQConsumer.scala
in rocketmq-spark/src/main/scala/org/apache/rocketmq/spark
 119 6 2
OffsetRange.scala
in rocketmq-spark/src/main/scala/org/apache/rocketmq/spark
 61 6 2
JmsBaseMessageProducer.java
in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain
 186 20 2
300-rocketmqsource.yaml
in rocketmq-knative/source/config
 75 - 2
mock_client.go
in rocketmq-knative/source/pkg/controller/testing
 100 8 2
interface.go
in rocketmq-knative/source/pkg/client/informers/externalversions/sources/v1alpha1
 18 2 2
clientset.go
in rocketmq-knative/source/pkg/client/clientset/versioned
 57 6 2
RocketMQ.java
in rocketmq-logstash-integration/rocketmq-logstash-output/src/main/java/org/apache/rocketmq/logstashplugin/output
 216 12 2
RocketmqLog4j2Appender.java
in logappender/src/main/java/org/apache/rocketmq/logappender/log4j2
 145 5 2
RocketmqLog4jAppender.java
in logappender/src/main/java/org/apache/rocketmq/logappender/log4j
 103 15 2
rmq_checkstyle.xml
in rocketmq-iot-bridge/style
 88 - 1
Apache.xml
in rocketmq-iot-bridge/style/copyright
 6 - 1
MqttSubscribeMessageHandler.java
in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl
 40 1 1
rmq_checkstyle.xml
in rocketmq-serializer/style
 86 - 1
Apache.xml
in rocketmq-serializer/style/copyright
 7 - 1
RocketMQMessageWriter.java
in rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl
 63 8 1
RocketMQHeaders.java
in rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl
 10 - 1
RocketMQBinaryMessageReader.java
in rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl
 35 6 1
content-script.js
in tools/chrome-plugin-rocketmq-helper/js
 55 3 1
rmq_checkstyle.xml
in rocketmq-spark/style
 86 - 1
Apache.xml
in rocketmq-spark/style/copyright
 7 - 1
JsonUtils.scala
in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq
 65 5 1
rmq_checkstyle.xml
in rocketmq-jms/style
 86 - 1
Apache.xml
in rocketmq-jms/style/copyright
 7 - 1
rmq_checkstyle.xml
in rocketmq-mysql/style
 85 - 1
Apache.xml
in rocketmq-mysql/style/copyright
 6 - 1
EventProcessor.java
in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog
 204 13 1
rmq_checkstyle.xml
in rocketmq-hbase/style
 85 - 1
Apache.xml
in rocketmq-hbase/style/copyright
 6 - 1
rocketmqsource_types.go
in rocketmq-knative/source/pkg/apis/sources/v1alpha1
 105 14 1
rocketmqsource.go
in rocketmq-knative/source/pkg/reconciler
 184 12 1
Correlations

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

rocketmq-spark/src/main/java/org/apache/rocketmq/spark/RocketMQConfig.java x: 3 commits (all time) y: 103 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/DefaultMessageRetryManager.java x: 3 commits (all time) y: 62 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/MQPullConsumerProvider.java x: 1 commits (all time) y: 26 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/MQPullConsumerProviderFactory.java x: 1 commits (all time) y: 5 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/MessageSet.java x: 4 commits (all time) y: 56 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/RocketMQReceiver.java x: 3 commits (all time) y: 90 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/SimpleMQPullConsumerProvider.java x: 1 commits (all time) y: 72 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/SimpleMQPullConsumerProviderFactory.java x: 1 commits (all time) y: 12 lines of code rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/CachedMQConsumer.scala x: 2 commits (all time) y: 119 lines of code rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/ConsumerProviderFactory.scala x: 1 commits (all time) y: 36 lines of code rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/RocketMqUtils.scala x: 4 commits (all time) y: 134 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/CachedRocketMQConsumer.scala x: 2 commits (all time) y: 267 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/CachedRocketMQProducer.scala x: 2 commits (all time) y: 61 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQOffsetReader.scala x: 2 commits (all time) y: 133 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQSqlUtils.scala x: 1 commits (all time) y: 23 lines of code rocketmq-spark/src/main/scala/org/apache/spark/streaming/MQPullInputDStream.scala x: 3 commits (all time) y: 399 lines of code rocketmq-spark/src/main/scala/org/apache/spark/streaming/RocketMqRDD.scala x: 2 commits (all time) y: 158 lines of code rocketmq-ansible/broker.yml x: 5 commits (all time) y: 3 lines of code rocketmq-ansible/rocketmq.yml x: 7 commits (all time) y: 22 lines of code rocketmq-ansible/roles/broker/tasks/main.yml x: 4 commits (all time) y: 44 lines of code rocketmq-ansible/roles/broker/vars/main.yml x: 6 commits (all time) y: 3 lines of code rocketmq-ansible/roles/exporter/tasks/main.yml x: 4 commits (all time) y: 38 lines of code rocketmq-ansible/roles/exporter/vars/main.yml x: 4 commits (all time) y: 2 lines of code rocketmq-ansible/roles/namesrv/tasks/main.yml x: 4 commits (all time) y: 37 lines of code rocketmq-beats-integration/libbeat/outputs/rocketmq/client.go x: 1 commits (all time) y: 105 lines of code rocketmq-beats-integration/libbeat/outputs/rocketmq/config.go x: 1 commits (all time) y: 31 lines of code rocketmq-beats-integration/libbeat/outputs/rocketmq/rocketmq.go x: 1 commits (all time) y: 41 lines of code rocketmq-logstash-integration/rocketmq-logstash-input/src/main/java/org/apache/rocketmq/logstashplugin/input/RocketMQ.java x: 1 commits (all time) y: 143 lines of code rocketmq-logstash-integration/rocketmq-logstash-output/src/main/java/org/apache/rocketmq/logstashplugin/output/RocketMQ.java x: 1 commits (all time) y: 216 lines of code logappender/src/main/java/org/apache/rocketmq/logappender/common/ProducerInstance.java x: 1 commits (all time) y: 59 lines of code logappender/src/main/java/org/apache/rocketmq/logappender/log4j/RocketmqLog4jAppender.java x: 1 commits (all time) y: 103 lines of code logappender/src/main/java/org/apache/rocketmq/logappender/log4j2/RocketmqLog4j2Appender.java x: 1 commits (all time) y: 145 lines of code logappender/src/main/java/org/apache/rocketmq/logappender/logback/RocketmqLogbackAppender.java x: 1 commits (all time) y: 101 lines of code tools/chrome-plugin-rocketmq-helper/js/content-script.js x: 1 commits (all time) y: 55 lines of code tools/chrome-plugin-rocketmq-helper/popup.js x: 1 commits (all time) y: 1 lines of code rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/RocketMQMessageFactory.java x: 2 commits (all time) y: 39 lines of code rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java x: 2 commits (all time) y: 35 lines of code rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQHeaders.java x: 2 commits (all time) y: 10 lines of code rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQMessageWriter.java x: 2 commits (all time) y: 63 lines of code rocketmq-flume/rocketmq-flume-source/src/main/java/org/apache/rocketmq/flume/ng/source/RocketMQSource.java x: 4 commits (all time) y: 109 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/MQTTBridge.java x: 3 commits (all time) y: 92 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/example/MqttSampleConsumer.java x: 3 commits (all time) y: 48 lines of code rocketmq-knative/source/config/500-controller.yaml x: 2 commits (all time) y: 25 lines of code rocketmq-knative/source/sample/apacherocketmqsource.yaml x: 1 commits (all time) y: 14 lines of code rocketmq-knative/source/sample/event-display.yaml x: 1 commits (all time) y: 10 lines of code rocketmq-knative/source/cmd/receive_adapter/main.go x: 2 commits (all time) y: 65 lines of code rocketmq-knative/source/pkg/adapter/adapter.go x: 2 commits (all time) y: 105 lines of code rocketmq-knative/source/pkg/reconciler/resources/receive_adapter.go x: 2 commits (all time) y: 96 lines of code rocketmq-knative/source/config/201-clusterrole.yaml x: 1 commits (all time) y: 43 lines of code rocketmq-knative/source/config/202-clusterrolebinding.yaml x: 1 commits (all time) y: 25 lines of code rocketmq-knative/source/config/300-rocketmqsource.yaml x: 1 commits (all time) y: 75 lines of code rocketmq-knative/source/config/600-istioegress.yaml x: 1 commits (all time) y: 17 lines of code rocketmq-knative/source/pkg/apis/addtoscheme_eventing_v1alpha1.go x: 1 commits (all time) y: 7 lines of code rocketmq-knative/source/pkg/apis/apis.go x: 1 commits (all time) y: 8 lines of code rocketmq-knative/source/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go x: 1 commits (all time) y: 77 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/clientset.go x: 1 commits (all time) y: 57 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/scheme/register.go x: 1 commits (all time) y: 20 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go x: 1 commits (all time) y: 2 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/typed/sources/v1alpha1/rocketmqsource.go x: 1 commits (all time) y: 142 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go x: 1 commits (all time) y: 54 lines of code rocketmq-knative/source/pkg/client/informers/externalversions/factory.go x: 1 commits (all time) y: 117 lines of code rocketmq-knative/source/pkg/client/informers/externalversions/generic.go x: 1 commits (all time) y: 28 lines of code rocketmq-knative/source/pkg/client/informers/externalversions/sources/v1alpha1/interface.go x: 1 commits (all time) y: 18 lines of code rocketmq-knative/source/pkg/client/listers/sources/v1alpha1/rocketmqsource.go x: 1 commits (all time) y: 52 lines of code rocketmq-knative/source/pkg/controller/sdk/finalizers_accessor.go x: 1 commits (all time) y: 45 lines of code rocketmq-knative/source/pkg/controller/sdk/reconciler.go x: 1 commits (all time) y: 128 lines of code rocketmq-knative/source/pkg/controller/sinks/sinks.go x: 1 commits (all time) y: 38 lines of code rocketmq-knative/source/pkg/controller/testing/mock_client.go x: 1 commits (all time) y: 100 lines of code rocketmq-knative/source/pkg/controller/testing/table.go x: 1 commits (all time) y: 173 lines of code rocketmq-knative/source/pkg/reconciler/creds.go x: 1 commits (all time) y: 37 lines of code rocketmq-knative/source/pkg/reconciler/eventtype/eventtype.go x: 1 commits (all time) y: 111 lines of code rocketmq-knative/source/pkg/reconciler/eventtype/resources/eventtype.go x: 1 commits (all time) y: 34 lines of code rocketmq-knative/source/pkg/reconciler/rocketmqsource.go x: 1 commits (all time) y: 184 lines of code rocketmq-flume/rocketmq-flume-sink/src/main/java/org/apache/rocketmq/flume/ng/sink/RocketMQSink.java x: 2 commits (all time) y: 174 lines of code rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/RocketMQRedisReplicator.java x: 9 commits (all time) y: 159 lines of code rocketmq-redis/src/main/resources/logback.xml x: 3 commits (all time) y: 29 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/common/data/Message.java x: 1 commits (all time) y: 64 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/common/util/MessageUtil.java x: 1 commits (all time) y: 191 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/MqttConnectionHandler.java x: 1 commits (all time) y: 60 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/MqttIdleHandler.java x: 1 commits (all time) y: 150 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl/MqttMessageForwarder.java x: 1 commits (all time) y: 47 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl/MqttPublishMessageHandler.java x: 1 commits (all time) y: 29 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl/MqttSubscribeMessageHandler.java x: 1 commits (all time) y: 40 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/storage/message/MessageStore.java x: 1 commits (all time) y: 15 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/storage/subscription/impl/InMemorySubscriptionStore.java x: 1 commits (all time) y: 121 lines of code rocketmq-iot-bridge/style/rmq_checkstyle.xml x: 1 commits (all time) y: 88 lines of code rocketmq-iot-bridge/style/rmq_codeStyle.xml x: 1 commits (all time) y: 126 lines of code rocketmq-hbase/rocketmq-hbase-sink/src/main/java/org/apache/rocketmq/hbase/sink/DataRow.java x: 1 commits (all time) y: 49 lines of code rocketmq-hbase/rocketmq-hbase-sink/src/main/java/org/apache/rocketmq/hbase/sink/Replicator.java x: 1 commits (all time) y: 107 lines of code rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source/Config.java x: 1 commits (all time) y: 114 lines of code rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source/HBaseClient.java x: 1 commits (all time) y: 48 lines of code rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source/RocketMQConsumer.java x: 1 commits (all time) y: 67 lines of code rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source/RocketMQSource.java x: 1 commits (all time) y: 21 lines of code rocketmq-hbase/style/rmq_checkstyle.xml x: 1 commits (all time) y: 85 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/JsonUtils.scala x: 1 commits (all time) y: 65 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQRelation.scala x: 1 commits (all time) y: 106 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQSource.scala x: 1 commits (all time) y: 249 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQSourceProvider.scala x: 1 commits (all time) y: 218 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQWriteTask.scala x: 1 commits (all time) y: 90 lines of code rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/conf/ReplicatorConstants.java x: 7 commits (all time) y: 15 lines of code rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/mq/KryoEventSerializer.java x: 1 commits (all time) y: 73 lines of code rocketmq-serializer/rocketmq-serializer-avro/src/main/java/org/apache/rocketmq/serializer/avro/RocketMQAvroSpecifiedSerializer.java x: 1 commits (all time) y: 32 lines of code rocketmq-serializer/rocketmq-serializer-core/src/main/java/org/apache/rocketmq/serializer/RocketMQDeserializer.java x: 1 commits (all time) y: 4 lines of code rocketmq-serializer/style/rmq_codeStyle.xml x: 1 commits (all time) y: 140 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message/JmsBaseMessage.java x: 3 commits (all time) y: 324 lines of code rocketmq-flume/rocketmq-flume-source/src/main/java/org/apache/rocketmq/flume/ng/source/RocketMQSourceConstants.java x: 2 commits (all time) y: 16 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/ReliableRocketMQReceiver.java x: 2 commits (all time) y: 77 lines of code rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/ConsumerStrategy.scala x: 2 commits (all time) y: 32 lines of code rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/conf/Configure.java x: 3 commits (all time) y: 63 lines of code rocketmq-redis/style/copyright/Apache.xml x: 2 commits (all time) y: 6 lines of code rocketmq-redis/style/copyright/profiles_settings.xml x: 2 commits (all time) y: 47 lines of code rocketmq-redis/style/rmq_checkstyle.xml x: 2 commits (all time) y: 85 lines of code rocketmq-redis/style/rmq_codeStyle.xml x: 2 commits (all time) y: 126 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog/DataRow.java x: 4 commits (all time) y: 48 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog/EventListener.java x: 4 commits (all time) y: 35 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog/EventProcessor.java x: 5 commits (all time) y: 204 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/position/BinlogPositionManager.java x: 5 commits (all time) y: 100 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/DateTimeColumnParser.java x: 3 commits (all time) y: 27 lines of code dev/merge_rocketmq_pr.py x: 1 commits (all time) y: 296 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/Config.java x: 4 commits (all time) y: 91 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/Replicator.java x: 3 commits (all time) y: 82 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/productor/RocketMQProducer.java x: 4 commits (all time) y: 27 lines of code rocketmq-mysql/src/main/resources/logback.xml x: 3 commits (all time) y: 54 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/Database.java x: 3 commits (all time) y: 68 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/Schema.java x: 3 commits (all time) y: 84 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/Table.java x: 3 commits (all time) y: 32 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/ColumnParser.java x: 3 commits (all time) y: 46 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/IntColumnParser.java x: 3 commits (all time) y: 39 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/StringColumnParser.java x: 3 commits (all time) y: 30 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/TimeColumnParser.java x: 3 commits (all time) y: 15 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/position/BinlogPosition.java x: 2 commits (all time) y: 21 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/DefaultColumnParser.java x: 2 commits (all time) y: 14 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/EnumColumnParser.java x: 2 commits (all time) y: 22 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseConnection.java x: 2 commits (all time) y: 120 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseConnectionFactory.java x: 2 commits (all time) y: 75 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseMessageConsumer.java x: 2 commits (all time) y: 123 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseMessageProducer.java x: 2 commits (all time) y: 186 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseSession.java x: 2 commits (all time) y: 199 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseTopic.java x: 2 commits (all time) y: 27 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/RMQPushConsumerExt.java x: 2 commits (all time) y: 89 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message/JmsBytesMessage.java x: 2 commits (all time) y: 175 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/util/ExceptionUtil.java x: 2 commits (all time) y: 20 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/util/MessageConverter.java x: 2 commits (all time) y: 142 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/util/MsgConvertUtil.java x: 2 commits (all time) y: 57 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/util/URISpecParser.java x: 2 commits (all time) y: 31 lines of code rocketmq-jms/spring/src/main/java/org/apache/rocketmq/jms/spring/SimpleExMessageListenerContainer.java x: 2 commits (all time) y: 29 lines of code rocketmq-jms/style/copyright/Apache.xml x: 2 commits (all time) y: 7 lines of code rocketmq-jms/style/rmq_codeStyle.xml x: 2 commits (all time) y: 140 lines of code
399.0
lines of code
  min: 1.0
  average: 57.19
  25th percentile: 15.25
  median: 38.5
  75th percentile: 85.0
  max: 399.0
0 9.0
commits (all time)
min: 1.0 | average: 1.69 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 9.0

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

rocketmq-spark/src/main/java/org/apache/rocketmq/spark/RocketMQConfig.java x: 3 contributors (all time) y: 103 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/DefaultMessageRetryManager.java x: 3 contributors (all time) y: 62 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/MQPullConsumerProvider.java x: 1 contributors (all time) y: 26 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/MQPullConsumerProviderFactory.java x: 1 contributors (all time) y: 5 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/MessageSet.java x: 4 contributors (all time) y: 56 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/RocketMQReceiver.java x: 3 contributors (all time) y: 90 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/SimpleMQPullConsumerProvider.java x: 1 contributors (all time) y: 72 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/SimpleMQPullConsumerProviderFactory.java x: 1 contributors (all time) y: 12 lines of code rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/CachedMQConsumer.scala x: 2 contributors (all time) y: 119 lines of code rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/ConsumerProviderFactory.scala x: 1 contributors (all time) y: 36 lines of code rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/RocketMqUtils.scala x: 4 contributors (all time) y: 134 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/CachedRocketMQConsumer.scala x: 2 contributors (all time) y: 267 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/CachedRocketMQProducer.scala x: 2 contributors (all time) y: 61 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQOffsetReader.scala x: 2 contributors (all time) y: 133 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQSqlUtils.scala x: 1 contributors (all time) y: 23 lines of code rocketmq-spark/src/main/scala/org/apache/spark/streaming/MQPullInputDStream.scala x: 3 contributors (all time) y: 399 lines of code rocketmq-spark/src/main/scala/org/apache/spark/streaming/RocketMqRDD.scala x: 2 contributors (all time) y: 158 lines of code rocketmq-ansible/broker.yml x: 2 contributors (all time) y: 3 lines of code rocketmq-ansible/rocketmq.yml x: 2 contributors (all time) y: 22 lines of code rocketmq-ansible/roles/broker/tasks/main.yml x: 2 contributors (all time) y: 44 lines of code rocketmq-ansible/roles/exporter/tasks/main.yml x: 2 contributors (all time) y: 38 lines of code rocketmq-ansible/roles/namesrv/tasks/main.yml x: 2 contributors (all time) y: 37 lines of code rocketmq-beats-integration/libbeat/outputs/rocketmq/client.go x: 1 contributors (all time) y: 105 lines of code rocketmq-beats-integration/libbeat/outputs/rocketmq/config.go x: 1 contributors (all time) y: 31 lines of code rocketmq-beats-integration/libbeat/outputs/rocketmq/rocketmq.go x: 1 contributors (all time) y: 41 lines of code rocketmq-logstash-integration/rocketmq-logstash-input/src/main/java/org/apache/rocketmq/logstashplugin/input/RocketMQ.java x: 1 contributors (all time) y: 143 lines of code rocketmq-logstash-integration/rocketmq-logstash-output/src/main/java/org/apache/rocketmq/logstashplugin/output/RocketMQ.java x: 1 contributors (all time) y: 216 lines of code logappender/src/main/java/org/apache/rocketmq/logappender/common/ProducerInstance.java x: 1 contributors (all time) y: 59 lines of code logappender/src/main/java/org/apache/rocketmq/logappender/log4j/RocketmqLog4jAppender.java x: 1 contributors (all time) y: 103 lines of code logappender/src/main/java/org/apache/rocketmq/logappender/log4j2/RocketmqLog4j2Appender.java x: 1 contributors (all time) y: 145 lines of code logappender/src/main/java/org/apache/rocketmq/logappender/logback/RocketmqLogbackAppender.java x: 1 contributors (all time) y: 101 lines of code tools/chrome-plugin-rocketmq-helper/js/content-script.js x: 1 contributors (all time) y: 55 lines of code tools/chrome-plugin-rocketmq-helper/popup.js x: 1 contributors (all time) y: 1 lines of code rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java x: 2 contributors (all time) y: 35 lines of code rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQHeaders.java x: 2 contributors (all time) y: 10 lines of code rocketmq-cloudevents-binding/src/main/java/org/apache/rocketmq/cloudevent/impl/RocketMQMessageWriter.java x: 2 contributors (all time) y: 63 lines of code rocketmq-flume/rocketmq-flume-source/src/main/java/org/apache/rocketmq/flume/ng/source/RocketMQSource.java x: 3 contributors (all time) y: 109 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/MQTTBridge.java x: 3 contributors (all time) y: 92 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/example/MqttSampleConsumer.java x: 3 contributors (all time) y: 48 lines of code rocketmq-knative/source/config/500-controller.yaml x: 1 contributors (all time) y: 25 lines of code rocketmq-knative/source/sample/apacherocketmqsource.yaml x: 1 contributors (all time) y: 14 lines of code rocketmq-knative/source/sample/event-display.yaml x: 1 contributors (all time) y: 10 lines of code rocketmq-knative/source/cmd/receive_adapter/main.go x: 1 contributors (all time) y: 65 lines of code rocketmq-knative/source/pkg/reconciler/resources/receive_adapter.go x: 1 contributors (all time) y: 96 lines of code rocketmq-knative/source/config/201-clusterrole.yaml x: 1 contributors (all time) y: 43 lines of code rocketmq-knative/source/config/300-rocketmqsource.yaml x: 1 contributors (all time) y: 75 lines of code rocketmq-knative/source/config/600-istioegress.yaml x: 1 contributors (all time) y: 17 lines of code rocketmq-knative/source/pkg/apis/addtoscheme_eventing_v1alpha1.go x: 1 contributors (all time) y: 7 lines of code rocketmq-knative/source/pkg/apis/apis.go x: 1 contributors (all time) y: 8 lines of code rocketmq-knative/source/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go x: 1 contributors (all time) y: 77 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/clientset.go x: 1 contributors (all time) y: 57 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/scheme/register.go x: 1 contributors (all time) y: 20 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go x: 1 contributors (all time) y: 2 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/typed/sources/v1alpha1/rocketmqsource.go x: 1 contributors (all time) y: 142 lines of code rocketmq-knative/source/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go x: 1 contributors (all time) y: 54 lines of code rocketmq-knative/source/pkg/client/informers/externalversions/factory.go x: 1 contributors (all time) y: 117 lines of code rocketmq-knative/source/pkg/client/informers/externalversions/generic.go x: 1 contributors (all time) y: 28 lines of code rocketmq-knative/source/pkg/client/informers/externalversions/sources/v1alpha1/interface.go x: 1 contributors (all time) y: 18 lines of code rocketmq-knative/source/pkg/client/listers/sources/v1alpha1/rocketmqsource.go x: 1 contributors (all time) y: 52 lines of code rocketmq-knative/source/pkg/controller/sdk/finalizers_accessor.go x: 1 contributors (all time) y: 45 lines of code rocketmq-knative/source/pkg/controller/sdk/reconciler.go x: 1 contributors (all time) y: 128 lines of code rocketmq-knative/source/pkg/controller/sinks/sinks.go x: 1 contributors (all time) y: 38 lines of code rocketmq-knative/source/pkg/controller/testing/mock_client.go x: 1 contributors (all time) y: 100 lines of code rocketmq-knative/source/pkg/controller/testing/table.go x: 1 contributors (all time) y: 173 lines of code rocketmq-knative/source/pkg/reconciler/creds.go x: 1 contributors (all time) y: 37 lines of code rocketmq-knative/source/pkg/reconciler/eventtype/eventtype.go x: 1 contributors (all time) y: 111 lines of code rocketmq-knative/source/pkg/reconciler/eventtype/resources/eventtype.go x: 1 contributors (all time) y: 34 lines of code rocketmq-knative/source/pkg/reconciler/rocketmqsource.go x: 1 contributors (all time) y: 184 lines of code rocketmq-flume/rocketmq-flume-sink/src/main/java/org/apache/rocketmq/flume/ng/sink/RocketMQSink.java x: 2 contributors (all time) y: 174 lines of code rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/RocketMQRedisReplicator.java x: 3 contributors (all time) y: 159 lines of code rocketmq-redis/src/main/resources/logback.xml x: 3 contributors (all time) y: 29 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/common/data/Message.java x: 1 contributors (all time) y: 64 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/common/util/MessageUtil.java x: 1 contributors (all time) y: 191 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/MqttConnectionHandler.java x: 1 contributors (all time) y: 60 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/MqttIdleHandler.java x: 1 contributors (all time) y: 150 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl/MqttMessageForwarder.java x: 1 contributors (all time) y: 47 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl/MqttPublishMessageHandler.java x: 1 contributors (all time) y: 29 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/impl/MqttSubscribeMessageHandler.java x: 1 contributors (all time) y: 40 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/storage/message/MessageStore.java x: 1 contributors (all time) y: 15 lines of code rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/storage/subscription/impl/InMemorySubscriptionStore.java x: 1 contributors (all time) y: 121 lines of code rocketmq-iot-bridge/style/rmq_checkstyle.xml x: 1 contributors (all time) y: 88 lines of code rocketmq-iot-bridge/style/rmq_codeStyle.xml x: 1 contributors (all time) y: 126 lines of code rocketmq-hbase/rocketmq-hbase-sink/src/main/java/org/apache/rocketmq/hbase/sink/DataRow.java x: 1 contributors (all time) y: 49 lines of code rocketmq-hbase/rocketmq-hbase-sink/src/main/java/org/apache/rocketmq/hbase/sink/Replicator.java x: 1 contributors (all time) y: 107 lines of code rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source/Config.java x: 1 contributors (all time) y: 114 lines of code rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source/HBaseClient.java x: 1 contributors (all time) y: 48 lines of code rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source/RocketMQConsumer.java x: 1 contributors (all time) y: 67 lines of code rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source/RocketMQSource.java x: 1 contributors (all time) y: 21 lines of code rocketmq-hbase/style/rmq_checkstyle.xml x: 1 contributors (all time) y: 85 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQRelation.scala x: 1 contributors (all time) y: 106 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQSource.scala x: 1 contributors (all time) y: 249 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQSourceProvider.scala x: 1 contributors (all time) y: 218 lines of code rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQWriteTask.scala x: 1 contributors (all time) y: 90 lines of code rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/conf/ReplicatorConstants.java x: 3 contributors (all time) y: 15 lines of code rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/mq/KryoEventSerializer.java x: 1 contributors (all time) y: 73 lines of code rocketmq-serializer/rocketmq-serializer-avro/src/main/java/org/apache/rocketmq/serializer/avro/RocketMQAvroSpecifiedSerializer.java x: 1 contributors (all time) y: 32 lines of code rocketmq-serializer/rocketmq-serializer-core/src/main/java/org/apache/rocketmq/serializer/RocketMQDeserializer.java x: 1 contributors (all time) y: 4 lines of code rocketmq-serializer/style/rmq_codeStyle.xml x: 1 contributors (all time) y: 140 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message/JmsBaseMessage.java x: 2 contributors (all time) y: 324 lines of code rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/ReliableRocketMQReceiver.java x: 2 contributors (all time) y: 77 lines of code rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/ConsumerStrategy.scala x: 2 contributors (all time) y: 32 lines of code rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/conf/ConfigureException.java x: 2 contributors (all time) y: 17 lines of code rocketmq-redis/style/copyright/Apache.xml x: 2 contributors (all time) y: 6 lines of code rocketmq-redis/style/copyright/profiles_settings.xml x: 2 contributors (all time) y: 47 lines of code rocketmq-redis/style/rmq_checkstyle.xml x: 2 contributors (all time) y: 85 lines of code rocketmq-redis/style/rmq_codeStyle.xml x: 2 contributors (all time) y: 126 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog/DataRow.java x: 2 contributors (all time) y: 48 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog/EventProcessor.java x: 2 contributors (all time) y: 204 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog/Transaction.java x: 2 contributors (all time) y: 55 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/position/BinlogPositionManager.java x: 2 contributors (all time) y: 100 lines of code dev/merge_rocketmq_pr.py x: 1 contributors (all time) y: 296 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/Config.java x: 2 contributors (all time) y: 91 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/Replicator.java x: 1 contributors (all time) y: 82 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/productor/RocketMQProducer.java x: 2 contributors (all time) y: 27 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/Database.java x: 2 contributors (all time) y: 68 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/Schema.java x: 2 contributors (all time) y: 84 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/StringColumnParser.java x: 2 contributors (all time) y: 30 lines of code rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/TimeColumnParser.java x: 2 contributors (all time) y: 15 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseConnection.java x: 1 contributors (all time) y: 120 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseMessageConsumer.java x: 1 contributors (all time) y: 123 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseMessageProducer.java x: 1 contributors (all time) y: 186 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseSession.java x: 1 contributors (all time) y: 199 lines of code rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message/JmsBytesMessage.java x: 1 contributors (all time) y: 175 lines of code
399.0
lines of code
  min: 1.0
  average: 57.19
  25th percentile: 15.25
  median: 38.5
  75th percentile: 85.0
  max: 399.0
0 4.0
contributors (all time)
min: 1.0 | average: 1.27 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 4.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): 0 points

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

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

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