apache / pulsar-connectors
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 218 files with 10,857 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 12 files changed 6-20 times (1,286 lines of code)
    • 206 files changed 1-5 times (9,571 lines of code)
0% | 0% | 0% | 11% | 88%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 218 files with 10,857 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 7 files changed by 6-10 contributors (847 lines of code)
    • 87 files changed by 2-5 contributors (5,034 lines of code)
    • 124 files changed by 1 contributor (4,976 lines of code)
0% | 0% | 7% | 46% | 45%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, yaml, xml, md, properties, txt, json, gitignore
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 12% | 87%
yaml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
pulsar-io0% | 0% | 0% | 11% | 88%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KinesisSink.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 176 10 2018-06-07 2020-05-19 15 7 rdhabalia@apache.org maths22@gmail.com
TwitterFireHose.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 125 6 2018-05-08 2020-03-27 14 7 lucperkins@gmail.com henry.yijieshen@gmail.com
KafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 108 6 2018-10-03 2020-05-28 9 6 jiazhai@users.noreply.githu... nathanm@instructure.com
KafkaAbstractSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 153 10 2018-06-08 2019-02-04 9 6 sanjeevrk@gmail.com sunfangbin@gmail.com
KafkaAbstractSink.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 72 4 2018-06-08 2019-02-04 8 5 sanjeevrk@gmail.com sunfangbin@gmail.com
RabbitMQSource.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 73 4 2018-05-08 2019-04-01 8 6 lucperkins@gmail.com sunfangbin@gmail.com
CassandraAbstractSink.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 75 4 2018-06-08 2019-10-31 7 4 sanjeevrk@gmail.com mmerli@apache.org
AerospikeAbstractSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 127 8 2018-06-08 2020-02-10 7 6 sanjeevrk@gmail.com abhilashmandaliya@gmail.com
KinesisSinkConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 54 2 2018-06-07 2019-09-05 6 3 rdhabalia@apache.org 35466513+david-streamlio@us...
ElasticSearchConfig.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 85 3 2018-09-10 2020-01-23 6 6 35466513+david-streamlio@us... yang.yang@elastic.co
ElasticSearchSink.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 114 8 2018-09-18 2020-09-08 6 5 guosijie@gmail.com rxl@apache.org
TwitterFireHoseConfig.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 124 5 2018-05-08 2020-01-01 6 5 lucperkins@gmail.com vzhikserg@users.noreply.git...
AerospikeStringSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 10 1 2018-06-08 2018-09-06 5 4 sanjeevrk@gmail.com alahmed.se@gmail.com
CassandraStringSink.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 17 1 2018-06-08 2018-11-27 5 3 sanjeevrk@gmail.com guosijie@gmail.com
KafkaSinkConfig.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 70 2 2018-05-08 2020-01-01 5 4 lucperkins@gmail.com vzhikserg@users.noreply.git...
KafkaSourceConfig.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 86 2 2018-05-08 2020-01-01 5 5 lucperkins@gmail.com vzhikserg@users.noreply.git...
RabbitMQAbstractConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 94 2 2019-04-01 2020-05-22 5 4 sunfangbin@gmail.com penghui@apache.org
Utils.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 160 4 2018-07-06 2020-09-30 5 3 rdhabalia@apache.org kellyfj@gmail.com
MongoSink.java
in pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb
 162 11 2019-02-13 2019-12-20 5 4 bbonnin@gmail.com localhost80@foxmail.com
AwsCredentialProviderPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 2018-06-07 2020-05-19 4 3 rdhabalia@apache.org maths22@gmail.com
pulsar-io.yaml
in pulsar-io/mongo/src/main/resources/META-INF/services
 6 - 2019-02-13 2020-05-22 4 3 bbonnin@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/kafka/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 4 3 mmerli@apache.org sanjeevrk@gmail.com
RabbitMQSinkConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 46 3 2019-04-02 2020-05-22 4 4 sunfangbin@gmail.com penghui@apache.org
CanalSourceConfig.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 65 2 2018-11-25 2020-01-01 4 4 eguangning@gmail.com vzhikserg@users.noreply.git...
RabbitMQSink.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 72 3 2019-04-02 2020-05-22 4 3 sunfangbin@gmail.com penghui@apache.org
RedisAbstractConfig.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis
 80 2 2019-03-12 2020-06-18 4 4 sunfangbin@gmail.com rdhabalia@apache.org
pulsar-io.yaml
in pulsar-io/aerospike/src/main/resources/META-INF/services
 4 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/elastic-search/src/main/resources/META-INF/services
 4 - 2018-09-10 2020-05-22 3 3 35466513+david-streamlio@us... sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/netty/src/main/resources/META-INF/services
 4 - 2018-12-16 2020-05-22 3 3 erenavsarogullari@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/canal/src/main/resources/META-INF/services
 4 - 2018-11-25 2020-05-22 3 2 eguangning@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/rabbitmq/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/kinesis/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
AerospikeSinkConfig.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 31 2 2018-05-08 2020-01-01 3 3 lucperkins@gmail.com vzhikserg@users.noreply.git...
HbaseAbstractConfig.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase
 39 1 2019-02-01 2020-01-01 3 2 1269223860@qq.com vzhikserg@users.noreply.git...
NettySourceConfig.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty
 44 2 2019-01-05 2020-01-01 3 3 1269223860@qq.com vzhikserg@users.noreply.git...
RabbitMQSourceConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 47 3 2019-04-01 2020-05-19 3 3 sunfangbin@gmail.com alex.rufo@teamcmp.com
CassandraSinkConfig.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 48 2 2018-05-08 2020-01-01 3 3 lucperkins@gmail.com vzhikserg@users.noreply.git...
HdfsSinkConfig.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 55 3 2018-12-16 2020-08-12 3 3 35466513+david-streamlio@us... xyzinfernity@163.com
KinesisRecord.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 57 4 2019-09-05 2019-11-06 3 3 35466513+david-streamlio@us... ke.like@outlook.com
HbaseSinkConfig.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink
 60 3 2019-02-01 2020-01-01 3 2 1269223860@qq.com vzhikserg@users.noreply.git...
SolrSinkConfig.java
in pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr
 64 3 2019-04-01 2020-01-01 3 2 sunfangbin@gmail.com vzhikserg@users.noreply.git...
MongoConfig.java
in pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb
 66 3 2019-02-13 2020-01-01 3 2 bbonnin@gmail.com vzhikserg@users.noreply.git...
HbaseGenericRecordSink.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink
 66 1 2019-02-01 2019-11-20 3 2 1269223860@qq.com chenyechao@gmail.com
SourceOfFlume.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink
 72 5 2019-03-04 2020-03-26 3 3 eguangning@gmail.com henry.yijieshen@gmail.com
KinesisSource.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 103 3 2019-09-05 2020-05-19 3 3 35466513+david-streamlio@us... maths22@gmail.com
NettyServer.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server
 141 13 2019-01-05 2019-12-14 3 3 1269223860@qq.com 58692163+gbensa@users.norep...
HbaseAbstractSink.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink
 145 6 2019-02-01 2020-01-01 3 3 1269223860@qq.com vzhikserg@users.noreply.git...
KinesisSourceConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 157 6 2019-09-05 2020-05-19 3 3 35466513+david-streamlio@us... maths22@gmail.com
AbstractHdfsConnector.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3
 165 13 2018-12-16 2019-12-20 3 3 35466513+david-streamlio@us... phreed@users.noreply.github...
AbstractHdfsConnector.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 165 13 2018-12-16 2019-12-20 3 3 35466513+david-streamlio@us... phreed@users.noreply.github...
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KinesisSink.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 176 10 2018-06-07 2020-05-19 15 7 rdhabalia@apache.org maths22@gmail.com
TwitterFireHose.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 125 6 2018-05-08 2020-03-27 14 7 lucperkins@gmail.com henry.yijieshen@gmail.com
KafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 108 6 2018-10-03 2020-05-28 9 6 jiazhai@users.noreply.githu... nathanm@instructure.com
KafkaAbstractSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 153 10 2018-06-08 2019-02-04 9 6 sanjeevrk@gmail.com sunfangbin@gmail.com
RabbitMQSource.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 73 4 2018-05-08 2019-04-01 8 6 lucperkins@gmail.com sunfangbin@gmail.com
AerospikeAbstractSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 127 8 2018-06-08 2020-02-10 7 6 sanjeevrk@gmail.com abhilashmandaliya@gmail.com
ElasticSearchConfig.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 85 3 2018-09-10 2020-01-23 6 6 35466513+david-streamlio@us... yang.yang@elastic.co
KafkaAbstractSink.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 72 4 2018-06-08 2019-02-04 8 5 sanjeevrk@gmail.com sunfangbin@gmail.com
TwitterFireHoseConfig.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 124 5 2018-05-08 2020-01-01 6 5 lucperkins@gmail.com vzhikserg@users.noreply.git...
ElasticSearchSink.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 114 8 2018-09-18 2020-09-08 6 5 guosijie@gmail.com rxl@apache.org
KafkaSourceConfig.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 86 2 2018-05-08 2020-01-01 5 5 lucperkins@gmail.com vzhikserg@users.noreply.git...
CassandraAbstractSink.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 75 4 2018-06-08 2019-10-31 7 4 sanjeevrk@gmail.com mmerli@apache.org
RabbitMQAbstractConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 94 2 2019-04-01 2020-05-22 5 4 sunfangbin@gmail.com penghui@apache.org
KafkaSinkConfig.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 70 2 2018-05-08 2020-01-01 5 4 lucperkins@gmail.com vzhikserg@users.noreply.git...
AerospikeStringSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 10 1 2018-06-08 2018-09-06 5 4 sanjeevrk@gmail.com alahmed.se@gmail.com
MongoSink.java
in pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb
 162 11 2019-02-13 2019-12-20 5 4 bbonnin@gmail.com localhost80@foxmail.com
RedisAbstractConfig.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis
 80 2 2019-03-12 2020-06-18 4 4 sunfangbin@gmail.com rdhabalia@apache.org
CanalSourceConfig.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 65 2 2018-11-25 2020-01-01 4 4 eguangning@gmail.com vzhikserg@users.noreply.git...
RabbitMQSinkConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 46 3 2019-04-02 2020-05-22 4 4 sunfangbin@gmail.com penghui@apache.org
KinesisSinkConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 54 2 2018-06-07 2019-09-05 6 3 rdhabalia@apache.org 35466513+david-streamlio@us...
Utils.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 160 4 2018-07-06 2020-09-30 5 3 rdhabalia@apache.org kellyfj@gmail.com
CassandraStringSink.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 17 1 2018-06-08 2018-11-27 5 3 sanjeevrk@gmail.com guosijie@gmail.com
AwsCredentialProviderPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 2018-06-07 2020-05-19 4 3 rdhabalia@apache.org maths22@gmail.com
RabbitMQSink.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 72 3 2019-04-02 2020-05-22 4 3 sunfangbin@gmail.com penghui@apache.org
pulsar-io.yaml
in pulsar-io/kafka/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 4 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/mongo/src/main/resources/META-INF/services
 6 - 2019-02-13 2020-05-22 4 3 bbonnin@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/kinesis/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
KinesisSourceConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 157 6 2019-09-05 2020-05-19 3 3 35466513+david-streamlio@us... maths22@gmail.com
KinesisSource.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 103 3 2019-09-05 2020-05-19 3 3 35466513+david-streamlio@us... maths22@gmail.com
KinesisRecord.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 57 4 2019-09-05 2019-11-06 3 3 35466513+david-streamlio@us... ke.like@outlook.com
SourceOfFlume.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink
 72 5 2019-03-04 2020-03-26 3 3 eguangning@gmail.com henry.yijieshen@gmail.com
HdfsSinkConfig.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 55 3 2018-12-16 2020-08-12 3 3 35466513+david-streamlio@us... xyzinfernity@163.com
AbstractHdfsConnector.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 165 13 2018-12-16 2019-12-20 3 3 35466513+david-streamlio@us... phreed@users.noreply.github...
AbstractHdfsConnector.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3
 165 13 2018-12-16 2019-12-20 3 3 35466513+david-streamlio@us... phreed@users.noreply.github...
pulsar-io.yaml
in pulsar-io/rabbitmq/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
RabbitMQSourceConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 47 3 2019-04-01 2020-05-19 3 3 sunfangbin@gmail.com alex.rufo@teamcmp.com
pulsar-io.yaml
in pulsar-io/netty/src/main/resources/META-INF/services
 4 - 2018-12-16 2020-05-22 3 3 erenavsarogullari@gmail.com sanjeevrk@gmail.com
NettyServer.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server
 141 13 2019-01-05 2019-12-14 3 3 1269223860@qq.com 58692163+gbensa@users.norep...
NettySourceConfig.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty
 44 2 2019-01-05 2020-01-01 3 3 1269223860@qq.com vzhikserg@users.noreply.git...
pulsar-io.yaml
in pulsar-io/elastic-search/src/main/resources/META-INF/services
 4 - 2018-09-10 2020-05-22 3 3 35466513+david-streamlio@us... sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/aerospike/src/main/resources/META-INF/services
 4 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
AerospikeSinkConfig.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 31 2 2018-05-08 2020-01-01 3 3 lucperkins@gmail.com vzhikserg@users.noreply.git...
CassandraSinkConfig.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 48 2 2018-05-08 2020-01-01 3 3 lucperkins@gmail.com vzhikserg@users.noreply.git...
HbaseAbstractSink.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink
 145 6 2019-02-01 2020-01-01 3 3 1269223860@qq.com vzhikserg@users.noreply.git...
PulsarDatabaseHistory.java
in pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium
 212 10 2019-03-19 2020-01-11 3 3 zhaijia@apache.org guangning@apache.org
pulsar-io.yaml
in pulsar-io/canal/src/main/resources/META-INF/services
 4 - 2018-11-25 2020-05-22 3 2 eguangning@gmail.com sanjeevrk@gmail.com
SolrSinkConfig.java
in pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr
 64 3 2019-04-01 2020-01-01 3 2 sunfangbin@gmail.com vzhikserg@users.noreply.git...
HbaseGenericRecordSink.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink
 66 1 2019-02-01 2019-11-20 3 2 1269223860@qq.com chenyechao@gmail.com
HbaseSinkConfig.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink
 60 3 2019-02-01 2020-01-01 3 2 1269223860@qq.com vzhikserg@users.noreply.git...
HbaseAbstractConfig.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase
 39 1 2019-02-01 2020-01-01 3 2 1269223860@qq.com vzhikserg@users.noreply.git...
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
AbstractKafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 207 10 2020-05-28 2020-05-28 1 1 nathanm@instructure.com nathanm@instructure.com
PulsarOffsetBackingStore.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 199 8 2018-10-03 2018-10-03 1 1 jiazhai@users.noreply.githu... jiazhai@users.noreply.githu...
Application.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 190 8 2019-03-04 2019-03-04 1 1 eguangning@gmail.com eguangning@gmail.com
DynamoDBSourceConfig.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 184 7 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
JdbcUtils.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 181 14 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
JdbcAbstractSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 180 5 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
FileListingThread.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 141 4 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
MessageUtils.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 116 2 2019-01-02 2019-01-02 1 1 eguangning@gmail.com eguangning@gmail.com
PollingPropertiesFileConfigurationProvider.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 110 7 2019-03-04 2019-03-04 1 1 eguangning@gmail.com eguangning@gmail.com
RedisSink.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink
 110 4 2019-03-12 2019-04-04 2 1 sunfangbin@gmail.com sunfangbin@gmail.com
InfluxDBSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 108 5 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
RedisSession.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis
 103 7 2019-03-12 2019-03-12 1 1 sunfangbin@gmail.com sunfangbin@gmail.com
DynamoDBSource.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 97 3 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
SolrAbstractSink.java
in pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr
 94 4 2019-04-01 2019-04-01 1 1 sunfangbin@gmail.com sunfangbin@gmail.com
TweetData.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data
 91 - 2019-01-11 2019-01-11 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
BatchSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb
 91 5 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
FlumeConnector.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume
 90 2 2019-03-04 2019-03-04 1 1 eguangning@gmail.com eguangning@gmail.com
NettyHttpServerHandler.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http
 90 6 2019-01-11 2019-01-11 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
InfluxDBSinkConfig.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 87 3 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
SinkOfFlume.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source
 86 5 2019-03-04 2019-03-04 1 1 eguangning@gmail.com eguangning@gmail.com
HdfsAbstractSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink
 85 7 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
AbstractAwsConnector.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 84 4 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
InfluxDBSinkConfig.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 83 3 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
StreamsRecordProcessor.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 77 5 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
BaseJdbcAutoSchemaSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 75 3 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
JdbcSinkConfig.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 73 2 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
FileConsumerThread.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 71 5 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
EncryptionCtx.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 60 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
DebeziumSource.java
in pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium
 59 4 2019-03-29 2019-03-29 1 1 zhaijia@apache.org zhaijia@apache.org
HdfsAbstractSequenceFileSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq
 58 5 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractSequenceFileSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq
 58 5 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
InfluxDBGenericRecordSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 57 1 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
InfluxDBAbstractSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 53 3 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
StreamsRecord.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 50 2 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
AbstractZooKeeperConfigurationProvider.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 48 3 2019-03-04 2019-03-04 1 1 eguangning@gmail.com eguangning@gmail.com
SimpleMaterializedConfiguration.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 46 8 2019-03-04 2019-03-04 1 1 eguangning@gmail.com eguangning@gmail.com
Message.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 45 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
HdfsSyncThread.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 45 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractTextFileSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text
 45 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsSyncThread.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink
 45 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractTextFileSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/text
 45 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
CanalStringSource.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 45 2 2019-01-02 2019-01-02 1 1 eguangning@gmail.com eguangning@gmail.com
EncryptionKey.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 44 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
KafkaSchemaWrappedSchema.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema
 40 3 2020-04-30 2020-04-30 1 1 guangning@apache.org guangning@apache.org
FileSource.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 38 2 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
TwitterRecord.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data
 37 4 2019-01-11 2019-01-11 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
FileRecord.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 37 4 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
JdbcDriverType.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 37 1 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
STSAssumeRoleProviderPlugin.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 37 3 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
NettyUDPServerHandler.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp
 36 3 2019-12-14 2019-12-14 1 1 58692163+gbensa@users.norep... 58692163+gbensa@users.norep...
Correlations

File Size vs. Number of Changes: 218 points

pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java x: 160 lines of code y: 5 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java x: 114 lines of code y: 6 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsAbstractSink.java x: 90 lines of code y: 2 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSinkConfig.java x: 55 lines of code y: 3 # changes pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java x: 80 lines of code y: 4 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 207 lines of code y: 1 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource.java x: 108 lines of code y: 9 # changes pulsar-io/aerospike/src/main/resources/META-INF/services/pulsar-io.yaml x: 4 lines of code y: 3 # changes pulsar-io/cassandra/src/main/resources/META-INF/services/pulsar-io.yaml x: 4 lines of code y: 2 # changes pulsar-io/flume/src/main/resources/META-INF/services/pulsar-io.yaml x: 5 lines of code y: 2 # changes pulsar-io/kafka/src/main/resources/META-INF/services/pulsar-io.yaml x: 6 lines of code y: 4 # changes pulsar-io/kinesis/src/main/resources/META-INF/services/pulsar-io.yaml x: 6 lines of code y: 3 # changes pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java x: 94 lines of code y: 5 # changes pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSink.java x: 72 lines of code y: 4 # changes pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSinkConfig.java x: 46 lines of code y: 4 # changes pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AbstractAwsConnector.java x: 84 lines of code y: 1 # changes pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AwsCredentialProviderPlugin.java x: 26 lines of code y: 1 # changes pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AwsDefaultProviderChainPlugin.java x: 21 lines of code y: 1 # changes pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/STSAssumeRoleProviderPlugin.java x: 37 lines of code y: 1 # changes pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSource.java x: 97 lines of code y: 1 # changes pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java x: 184 lines of code y: 1 # changes pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecord.java x: 50 lines of code y: 1 # changes pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessor.java x: 77 lines of code y: 1 # changes pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessorFactory.java x: 17 lines of code y: 1 # changes pulsar-io/dynamodb/src/main/resources/META-INF/services/pulsar-io.yaml x: 3 lines of code y: 1 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/AwsCredentialProviderPlugin.java x: 4 lines of code y: 4 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java x: 176 lines of code y: 15 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSource.java x: 103 lines of code y: 3 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java x: 157 lines of code y: 3 # changes pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSourceConfig.java x: 47 lines of code y: 3 # changes pulsar-io/jdbc/clickhouse/src/main/java/org/apache/pulsar/io/jdbc/ClickHouseJdbcAutoSchemaSink.java x: 11 lines of code y: 1 # changes pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java x: 75 lines of code y: 1 # changes pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java x: 180 lines of code y: 1 # changes pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcSinkConfig.java x: 73 lines of code y: 1 # changes pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcUtils.java x: 181 lines of code y: 1 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/KafkaSchemaWrappedSchema.java x: 40 lines of code y: 1 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/BatchSink.java x: 91 lines of code y: 1 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBGenericRecordSink.java x: 48 lines of code y: 2 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBAbstractSink.java x: 53 lines of code y: 1 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBBuilder.java x: 5 lines of code y: 1 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBBuilderImpl.java x: 33 lines of code y: 1 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBGenericRecordSink.java x: 57 lines of code y: 1 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfig.java x: 87 lines of code y: 1 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBClientBuilderImpl.java x: 23 lines of code y: 1 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSink.java x: 108 lines of code y: 1 # changes pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkConfig.java x: 83 lines of code y: 1 # changes pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java x: 125 lines of code y: 14 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/SourceOfFlume.java x: 72 lines of code y: 3 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsSequentialTextSink.java x: 38 lines of code y: 2 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsTextSink.java x: 27 lines of code y: 2 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text/HdfsStringSink.java x: 11 lines of code y: 2 # changes pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeAbstractSink.java x: 127 lines of code y: 7 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java x: 470 lines of code y: 2 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java x: 85 lines of code y: 6 # changes pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java x: 212 lines of code y: 3 # changes pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeSinkConfig.java x: 31 lines of code y: 3 # changes pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalSourceConfig.java x: 65 lines of code y: 4 # changes pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraSinkConfig.java x: 48 lines of code y: 3 # changes pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSourceConfig.java x: 78 lines of code y: 2 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConfig.java x: 45 lines of code y: 2 # changes pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java x: 39 lines of code y: 3 # changes pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java x: 145 lines of code y: 3 # changes pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseSinkConfig.java x: 60 lines of code y: 3 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConfig.java x: 25 lines of code y: 2 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java x: 70 lines of code y: 5 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java x: 86 lines of code y: 5 # changes pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoConfig.java x: 66 lines of code y: 3 # changes pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/NettySourceConfig.java x: 44 lines of code y: 3 # changes pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink/RedisSinkConfig.java x: 50 lines of code y: 2 # changes pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrSinkConfig.java x: 64 lines of code y: 3 # changes pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHoseConfig.java x: 124 lines of code y: 6 # changes pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSink.java x: 162 lines of code y: 5 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PropertiesFileConfigurationProvider.java x: 54 lines of code y: 2 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java x: 165 lines of code y: 3 # changes pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyServer.java x: 141 lines of code y: 3 # changes pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPChannelInitializer.java x: 16 lines of code y: 1 # changes pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/package-info.java x: 1 lines of code y: 1 # changes pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPChannelInitializer.java x: 14 lines of code y: 1 # changes pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPServerHandler.java x: 36 lines of code y: 1 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecord.java x: 57 lines of code y: 3 # changes pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSource.java x: 111 lines of code y: 2 # changes pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraAbstractSink.java x: 75 lines of code y: 7 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/BaseKinesisConfig.java x: 43 lines of code y: 2 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessor.java x: 84 lines of code y: 2 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessorFactory.java x: 17 lines of code y: 2 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSinkConfig.java x: 54 lines of code y: 6 # changes pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java x: 131 lines of code y: 2 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PollingZooKeeperConfigurationProvider.java x: 94 lines of code y: 2 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java x: 87 lines of code y: 2 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarIOSourceTaskContext.java x: 20 lines of code y: 2 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/AbstractSink.java x: 44 lines of code y: 2 # changes pulsar-io/file/src/main/java/org/apache/pulsar/io/file/utils/GZipFiles.java x: 51 lines of code y: 2 # changes pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink/RedisSink.java x: 110 lines of code y: 2 # changes pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrAbstractSink.java x: 94 lines of code y: 1 # changes pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrGenericRecordSink.java x: 29 lines of code y: 1 # changes pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java x: 73 lines of code y: 8 # changes pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/DebeziumSource.java x: 59 lines of code y: 1 # changes pulsar-io/debezium/postgres/src/main/resources/debezium-postgres-source-config.yaml x: 15 lines of code y: 1 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaWorkerConfig.java x: 34 lines of code y: 2 # changes pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisSession.java x: 103 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConnector.java x: 90 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractZooKeeperConfigurationProvider.java x: 48 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java x: 190 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/ConfigurationProvider.java x: 4 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/EnvVarResolverProperties.java x: 24 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/MaterializedConfiguration.java x: 13 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PollingPropertiesFileConfigurationProvider.java x: 110 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/SimpleMaterializedConfiguration.java x: 46 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/StaticZooKeeperConfigurationProvider.java x: 31 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/StringSink.java x: 8 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSinkOfFlume.java x: 10 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/SinkOfFlume.java x: 86 lines of code y: 1 # changes pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/StringSource.java x: 7 lines of code y: 1 # changes pulsar-io/flume/src/main/resources/flume/flume-io-sink.yaml x: 6 lines of code y: 1 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java x: 72 lines of code y: 8 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java x: 153 lines of code y: 9 # changes pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http/NettyHttpChannelInitializer.java x: 22 lines of code y: 1 # changes pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalStringSource.java x: 45 lines of code y: 1 # changes pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/MessageUtils.java x: 116 lines of code y: 1 # changes pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileConsumerThread.java x: 71 lines of code y: 1 # changes pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileListingThread.java x: 141 lines of code y: 1 # changes pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSource.java x: 38 lines of code y: 1 # changes pulsar-io/file/src/main/java/org/apache/pulsar/io/file/ProcessedFileThread.java x: 32 lines of code y: 1 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/SecurityUtil.java x: 27 lines of code y: 1 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsAbstractSequenceFileSink.java x: 58 lines of code y: 1 # changes pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsAbstractSink.java x: 85 lines of code y: 1 # changes pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraStringSink.java x: 17 lines of code y: 5 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaBytesSink.java x: 30 lines of code y: 2 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaBytesSource.java x: 29 lines of code y: 2 # changes pulsar-io/canal/src/main/resources/canal-mysql-source-config.yaml x: 9 lines of code y: 1 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java x: 199 lines of code y: 1 # changes pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeStringSink.java x: 10 lines of code y: 5 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaStringSource.java x: 8 lines of code y: 2 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs/EncryptionCtx.java x: 60 lines of code y: 1 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs/EncryptionKey.java x: 44 lines of code y: 1 # changes
15.0
# changes
  min: 1.0
  average: 2.08
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 15.0
0 470.0
lines of code
min: 1.0 | average: 49.8 | 25th percentile: 6.0 | median: 35.0 | 75th percentile: 73.5 | max: 470.0

Number of Contributors vs. Number of Changes: 218 points

pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java x: 3 # contributors y: 5 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java x: 5 # contributors y: 6 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsAbstractSink.java x: 2 # contributors y: 2 # changes pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSinkConfig.java x: 3 # contributors y: 3 # changes pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java x: 4 # contributors y: 4 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 1 # contributors y: 1 # changes pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource.java x: 6 # contributors y: 9 # changes pulsar-io/canal/src/main/resources/META-INF/services/pulsar-io.yaml x: 2 # contributors y: 3 # changes pulsar-io/kafka/src/main/resources/META-INF/services/pulsar-io.yaml x: 3 # contributors y: 4 # changes pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java x: 4 # contributors y: 5 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java x: 7 # contributors y: 15 # changes pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java x: 7 # contributors y: 14 # changes pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeAbstractSink.java x: 6 # contributors y: 7 # changes pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java x: 6 # contributors y: 6 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java x: 5 # contributors y: 5 # changes pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraAbstractSink.java x: 4 # contributors y: 7 # changes pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSinkConfig.java x: 3 # contributors y: 6 # changes pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink/RedisSink.java x: 1 # contributors y: 2 # changes pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java x: 6 # contributors y: 8 # changes pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java x: 5 # contributors y: 8 # changes
15.0
# changes
  min: 1.0
  average: 2.08
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 15.0
0 7.0
# contributors
min: 1.0 | average: 1.82 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 7.0

Number of Contributors vs. File Size: 218 points

pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java x: 3 # contributors y: 160 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java x: 5 # contributors y: 114 lines of code pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsAbstractSink.java x: 2 # contributors y: 90 lines of code pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSinkConfig.java x: 3 # contributors y: 55 lines of code pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java x: 4 # contributors y: 80 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 1 # contributors y: 207 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource.java x: 6 # contributors y: 108 lines of code pulsar-io/aerospike/src/main/resources/META-INF/services/pulsar-io.yaml x: 3 # contributors y: 4 lines of code pulsar-io/canal/src/main/resources/META-INF/services/pulsar-io.yaml x: 2 # contributors y: 4 lines of code pulsar-io/kafka/src/main/resources/META-INF/services/pulsar-io.yaml x: 3 # contributors y: 6 lines of code pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQAbstractConfig.java x: 4 # contributors y: 94 lines of code pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSink.java x: 3 # contributors y: 72 lines of code pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSinkConfig.java x: 4 # contributors y: 46 lines of code pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AbstractAwsConnector.java x: 1 # contributors y: 84 lines of code pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AwsCredentialProviderPlugin.java x: 1 # contributors y: 26 lines of code pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/AwsDefaultProviderChainPlugin.java x: 1 # contributors y: 21 lines of code pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws/STSAssumeRoleProviderPlugin.java x: 1 # contributors y: 37 lines of code pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSource.java x: 1 # contributors y: 97 lines of code pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java x: 1 # contributors y: 184 lines of code pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecord.java x: 1 # contributors y: 50 lines of code pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessor.java x: 1 # contributors y: 77 lines of code pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/StreamsRecordProcessorFactory.java x: 1 # contributors y: 17 lines of code pulsar-io/dynamodb/src/main/resources/META-INF/services/pulsar-io.yaml x: 1 # contributors y: 3 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java x: 7 # contributors y: 176 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSource.java x: 3 # contributors y: 103 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java x: 3 # contributors y: 157 lines of code pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSourceConfig.java x: 3 # contributors y: 47 lines of code pulsar-io/jdbc/clickhouse/src/main/java/org/apache/pulsar/io/jdbc/ClickHouseJdbcAutoSchemaSink.java x: 1 # contributors y: 11 lines of code pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java x: 1 # contributors y: 75 lines of code pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java x: 1 # contributors y: 180 lines of code pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcSinkConfig.java x: 1 # contributors y: 73 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/KafkaSchemaWrappedSchema.java x: 1 # contributors y: 40 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/BatchSink.java x: 1 # contributors y: 91 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBGenericRecordSink.java x: 2 # contributors y: 48 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBAbstractSink.java x: 1 # contributors y: 53 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBBuilder.java x: 1 # contributors y: 5 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBBuilderImpl.java x: 1 # contributors y: 33 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBGenericRecordSink.java x: 1 # contributors y: 57 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfig.java x: 1 # contributors y: 87 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBClientBuilderImpl.java x: 1 # contributors y: 23 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSink.java x: 1 # contributors y: 108 lines of code pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2/InfluxDBSinkConfig.java x: 1 # contributors y: 83 lines of code pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java x: 7 # contributors y: 125 lines of code pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsSequentialTextSink.java x: 2 # contributors y: 38 lines of code pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq/HdfsTextSink.java x: 2 # contributors y: 27 lines of code pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text/HdfsStringSink.java x: 2 # contributors y: 11 lines of code pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeAbstractSink.java x: 6 # contributors y: 127 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java x: 2 # contributors y: 470 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java x: 6 # contributors y: 85 lines of code pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/PulsarDatabaseHistory.java x: 3 # contributors y: 212 lines of code pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeSinkConfig.java x: 3 # contributors y: 31 lines of code pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalSourceConfig.java x: 4 # contributors y: 65 lines of code pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSourceConfig.java x: 2 # contributors y: 78 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConfig.java x: 2 # contributors y: 45 lines of code pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java x: 2 # contributors y: 39 lines of code pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseAbstractSink.java x: 3 # contributors y: 145 lines of code pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink/HbaseSinkConfig.java x: 2 # contributors y: 60 lines of code pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConfig.java x: 2 # contributors y: 25 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java x: 4 # contributors y: 70 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java x: 5 # contributors y: 86 lines of code pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoConfig.java x: 2 # contributors y: 66 lines of code pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/NettySourceConfig.java x: 3 # contributors y: 44 lines of code pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink/RedisSinkConfig.java x: 2 # contributors y: 50 lines of code pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrSinkConfig.java x: 2 # contributors y: 64 lines of code pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHoseConfig.java x: 5 # contributors y: 124 lines of code pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSink.java x: 4 # contributors y: 162 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PropertiesFileConfigurationProvider.java x: 2 # contributors y: 54 lines of code pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java x: 3 # contributors y: 165 lines of code pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server/NettyServer.java x: 3 # contributors y: 141 lines of code pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/NettyTCPChannelInitializer.java x: 1 # contributors y: 16 lines of code pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp/package-info.java x: 1 # contributors y: 1 lines of code pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp/NettyUDPChannelInitializer.java x: 1 # contributors y: 14 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecord.java x: 3 # contributors y: 57 lines of code pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSource.java x: 2 # contributors y: 111 lines of code pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraAbstractSink.java x: 4 # contributors y: 75 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/BaseKinesisConfig.java x: 2 # contributors y: 43 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessor.java x: 2 # contributors y: 84 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisRecordProcessorFactory.java x: 2 # contributors y: 17 lines of code pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java x: 2 # contributors y: 131 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PollingZooKeeperConfigurationProvider.java x: 2 # contributors y: 94 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java x: 2 # contributors y: 87 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarIOSourceTaskContext.java x: 2 # contributors y: 20 lines of code pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink/RedisSink.java x: 1 # contributors y: 110 lines of code pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrAbstractSink.java x: 1 # contributors y: 94 lines of code pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrGenericRecordSink.java x: 1 # contributors y: 29 lines of code pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java x: 6 # contributors y: 73 lines of code pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/DebeziumSource.java x: 1 # contributors y: 59 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaWorkerConfig.java x: 2 # contributors y: 34 lines of code pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisSession.java x: 1 # contributors y: 103 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConnector.java x: 1 # contributors y: 90 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractZooKeeperConfigurationProvider.java x: 1 # contributors y: 48 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java x: 1 # contributors y: 190 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/SimpleMaterializedConfiguration.java x: 1 # contributors y: 46 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/StaticZooKeeperConfigurationProvider.java x: 1 # contributors y: 31 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/StringSink.java x: 1 # contributors y: 8 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/SinkOfFlume.java x: 1 # contributors y: 86 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/StringSource.java x: 1 # contributors y: 7 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java x: 5 # contributors y: 72 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java x: 6 # contributors y: 153 lines of code pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/MessageUtils.java x: 1 # contributors y: 116 lines of code pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileConsumerThread.java x: 1 # contributors y: 71 lines of code pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileListingThread.java x: 1 # contributors y: 141 lines of code pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSource.java x: 1 # contributors y: 38 lines of code pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraStringSink.java x: 3 # contributors y: 17 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java x: 1 # contributors y: 199 lines of code pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeStringSink.java x: 4 # contributors y: 10 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaStringSource.java x: 2 # contributors y: 8 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs/EncryptionCtx.java x: 1 # contributors y: 60 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs/EncryptionKey.java x: 1 # contributors y: 44 lines of code
470.0
lines of code
  min: 1.0
  average: 49.8
  25th percentile: 6.0
  median: 35.0
  75th percentile: 73.5
  max: 470.0
0 7.0
# contributors
min: 1.0 | average: 1.82 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 7.0