apache / pulsar-connectors
File Size

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

Intro
Learn more...
File Size Overall
0% | 0% | 8% | 36% | 55%
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
java0% | 0% | 8% | 37% | 54%
yaml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
pulsar-io0% | 0% | 8% | 36% | 55%
Longest Files (Top 50)
File# lines# units
AbstractConfigurationProvider.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 470 12
PulsarDatabaseHistory.java
in pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium
 212 10
AbstractKafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 207 10
PulsarOffsetBackingStore.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 199 8
Application.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 190 8
DynamoDBSourceConfig.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 184 7
JdbcUtils.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 181 14
JdbcAbstractSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 180 5
KinesisSink.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 176 10
AbstractHdfsConnector.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 165 13
AbstractHdfsConnector.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3
 165 13
MongoSink.java
in pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb
 162 11
Utils.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 160 4
KinesisSourceConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 157 6
KafkaAbstractSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 153 10
HbaseAbstractSink.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink
 145 6
FileListingThread.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 141 4
NettyServer.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server
 141 13
CanalAbstractSource.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 131 9
AerospikeAbstractSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 127 8
TwitterFireHose.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 125 6
TwitterFireHoseConfig.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 124 5
MessageUtils.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 116 2
ElasticSearchSink.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 114 8
MongoSource.java
in pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb
 111 4
PollingPropertiesFileConfigurationProvider.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 110 7
RedisSink.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink
 110 4
KafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 108 6
InfluxDBSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 108 5
KinesisSource.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 103 3
RedisSession.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis
 103 7
DynamoDBSource.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 97 3
PollingZooKeeperConfigurationProvider.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 94 6
RabbitMQAbstractConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 94 2
SolrAbstractSink.java
in pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr
 94 4
TweetData.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data
 91 -
BatchSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb
 91 5
FlumeConnector.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume
 90 2
HdfsAbstractSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 90 6
NettyHttpServerHandler.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http
 90 6
AbstractSource.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source
 87 6
InfluxDBSinkConfig.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 87 3
SinkOfFlume.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source
 86 5
KafkaSourceConfig.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 86 2
HdfsAbstractSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink
 85 7
ElasticSearchConfig.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 85 3
KinesisRecordProcessor.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 84 7
AbstractAwsConnector.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 84 4
InfluxDBSinkConfig.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 83 3
RedisAbstractConfig.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis
 80 2
Files With Most Units (Top 50)
File# lines# units
JdbcUtils.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 181 14
AbstractHdfsConnector.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 165 13
AbstractHdfsConnector.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3
 165 13
NettyServer.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server
 141 13
AbstractConfigurationProvider.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 470 12
MongoSink.java
in pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb
 162 11
KinesisSink.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 176 10
AbstractKafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 207 10
KafkaAbstractSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 153 10
PulsarDatabaseHistory.java
in pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium
 212 10
CanalAbstractSource.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 131 9
PulsarOffsetBackingStore.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 199 8
Application.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 190 8
SimpleMaterializedConfiguration.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 46 8
ElasticSearchSink.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 114 8
AerospikeAbstractSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 127 8
KinesisRecordProcessor.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 84 7
PollingPropertiesFileConfigurationProvider.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 110 7
HdfsAbstractSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink
 85 7
RedisSession.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis
 103 7
DynamoDBSourceConfig.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 184 7
KinesisSourceConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 157 6
KafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 108 6
TwitterFireHose.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 125 6
AbstractSource.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source
 87 6
PollingZooKeeperConfigurationProvider.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 94 6
HdfsAbstractSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 90 6
NettyHttpServerHandler.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http
 90 6
HbaseAbstractSink.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink
 145 6
TwitterFireHoseConfig.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 124 5
SinkOfFlume.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source
 86 5
SourceOfFlume.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink
 72 5
HdfsAbstractSequenceFileSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq
 58 5
HdfsAbstractSequenceFileSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq
 58 5
FileConsumerThread.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 71 5
StreamsRecordProcessor.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 77 5
JdbcAbstractSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 180 5
InfluxDBSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 108 5
BatchSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb
 91 5
Utils.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 160 4
KinesisRecord.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 57 4
TwitterRecord.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data
 37 4
AbstractSink.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink
 44 4
HdfsSyncThread.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 45 4
HdfsSequentialTextSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq
 38 4
HdfsAbstractTextFileSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text
 45 4
HdfsResources.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 23 4
HdfsSyncThread.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink
 45 4
HdfsSequentialTextSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq
 38 4
HdfsAbstractTextFileSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/text
 45 4
Files With Long Lines (Top 33)

There are 33 files with lines longer than 120 characters. In total, there are 72 long lines.

File# lines# units# long lines
Message.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 45 2 11
EncryptionCtx.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 60 2 8
EncryptionKey.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 44 2 7
DynamoDBSourceConfig.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 184 7 5
KafkaAbstractSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 153 10 4
CanalAbstractSource.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 131 9 3
ElasticSearchConfig.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 85 3 3
KinesisSink.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 176 10 2
AbstractKafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 207 10 2
RedisSink.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/sink
 110 4 2
DynamoDBSource.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 97 3 2
JdbcAbstractSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 180 5 2
Utils.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 160 4 1
STSAssumeRoleProviderPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 1
KeyValue.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 33 2 1
AwsDefaultProviderChainPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 1
KinesisSinkConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 54 2 1
KafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 108 6 1
TwitterFireHose.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 125 6 1
AbstractSource.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source
 87 6 1
AbstractConfigurationProvider.java
in pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node
 470 12 1
RedisSession.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis
 103 7 1
RabbitMQSource.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 73 4 1
RabbitMQSink.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 72 3 1
SolrSinkConfig.java
in pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr
 64 3 1
BaseJdbcAutoSchemaSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 75 3 1
InfluxDBAbstractSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 53 3 1
InfluxDBSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 108 5 1
KafkaAbstractSink.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 72 4 1
AerospikeAbstractSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 127 8 1
HbaseAbstractSink.java
in pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/sink
 145 6 1
AbstractAwsConnector.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 84 4 1
PulsarDatabaseHistory.java
in pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium
 212 10 1
Correlations

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

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

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

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