apache / incubator-pekko-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 642 files with 44,164 lines of code.
    • 3 files changed more than 100 times (751 lines of code)
    • 1 file changed 51-100 times (95 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 71 files changed 6-20 times (10,807 lines of code)
    • 567 files changed 1-5 times (32,511 lines of code)
1% | <1% | 0% | 24% | 73%
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 642 files with 44,164 lines of code.
    • 2 files changed by more than 25 contributors (727 lines of code)
    • 2 files changed by 11-25 contributors (119 lines of code)
    • 1 file changed by 6-10 contributors (41 lines of code)
    • 490 files changed by 2-5 contributors (38,198 lines of code)
    • 147 files changed by 1 contributor (5,079 lines of code)
1% | <1% | <1% | 86% | 11%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
scala, java, md, xml, yml, sh, txt, pub, json, yaml, sbt, svg, properties, gitignore, gitattributes
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
sbt100% | 0% | 0% | 0% | 0%
scala<1% | <1% | 0% | 25% | 73%
java0% | 0% | 0% | 0% | 100%
xml0% | 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
ROOT100% | 0% | 0% | 0% | 0%
project53% | 13% | 0% | 24% | 8%
s30% | 0% | 0% | 57% | 42%
google-cloud-bigquery0% | 0% | 0% | 45% | 54%
amqp0% | 0% | 0% | 46% | 53%
jms0% | 0% | 0% | 27% | 72%
mqtt-streaming0% | 0% | 0% | 19% | 80%
google-cloud-storage0% | 0% | 0% | 31% | 68%
google-cloud-bigquery-storage0% | 0% | 0% | 48% | 51%
sqs0% | 0% | 0% | 36% | 63%
elasticsearch0% | 0% | 0% | 25% | 74%
solr0% | 0% | 0% | 59% | 40%
kinesis0% | 0% | 0% | 35% | 64%
google-cloud-pub-sub0% | 0% | 0% | 47% | 52%
cassandra0% | 0% | 0% | 34% | 65%
mqtt0% | 0% | 0% | 26% | 73%
couchbase0% | 0% | 0% | 15% | 84%
influxdb0% | 0% | 0% | 24% | 75%
xml0% | 0% | 0% | 24% | 75%
reference0% | 0% | 0% | 38% | 61%
orientdb0% | 0% | 0% | 30% | 69%
mongodb0% | 0% | 0% | 45% | 54%
kudu0% | 0% | 0% | 32% | 67%
google-common0% | 0% | 0% | 3% | 96%
azure-storage-queue0% | 0% | 0% | 24% | 75%
testkit0% | 0% | 0% | 26% | 73%
file0% | 0% | 0% | 3% | 96%
ftp0% | 0% | 0% | 0% | 100%
pravega0% | 0% | 0% | 0% | 100%
google-fcm0% | 0% | 0% | 0% | 100%
csv0% | 0% | 0% | 0% | 100%
huawei-push-kit0% | 0% | 0% | 0% | 100%
geode0% | 0% | 0% | 0% | 100%
hdfs0% | 0% | 0% | 0% | 100%
ironmq0% | 0% | 0% | 0% | 100%
unix-domain-socket0% | 0% | 0% | 0% | 100%
google-cloud-pub-sub-grpc0% | 0% | 0% | 0% | 100%
udp0% | 0% | 0% | 0% | 100%
hbase0% | 0% | 0% | 0% | 100%
slick0% | 0% | 0% | 0% | 100%
mqtt-streaming-bench0% | 0% | 0% | 0% | 100%
text0% | 0% | 0% | 0% | 100%
avroparquet0% | 0% | 0% | 0% | 100%
dynamodb0% | 0% | 0% | 0% | 100%
sse0% | 0% | 0% | 0% | 100%
simple-codecs0% | 0% | 0% | 0% | 100%
sns0% | 0% | 0% | 0% | 100%
aws-event-bridge0% | 0% | 0% | 0% | 100%
spring-web0% | 0% | 0% | 0% | 100%
json-streaming0% | 0% | 0% | 0% | 100%
csv-bench0% | 0% | 0% | 0% | 100%
scripts0% | 0% | 0% | 0% | 100%
awslambda0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
344 1 2016-10-26 2023-08-03 363 102 mmartynas@gmail.com pjfanning@users.noreply.git...
build.sbt
in root
 383 2 2016-05-10 2023-08-06 286 66 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
plugins.sbt
in project
 24 - 2016-05-10 2023-08-06 136 22 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
Common.scala
in project
 95 1 2016-08-11 2023-06-23 75 18 mmartynas@gmail.com pjfanning@users.noreply.git...
41 1 2017-09-18 2023-06-23 13 9 github@bzzt.net pjfanning@users.noreply.git...
BigQueryAvroStorage.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl
 154 4 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryArrowStorage.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl
 163 4 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 655 19 2023-03-14 2023-06-26 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 936 61 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsPublishSink.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl
 58 - 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in reference/src/main/scala/org/apache/pekko/stream/connectors/reference
 68 6 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ElasticsearchConnectionSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 78 3 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsPublishFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 95 2 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryStorage.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl
 105 1 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GCStorage.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/javadsl
 129 2 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQuery.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl
 182 9 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 708 48 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1271 52 2023-03-14 2023-06-23 8 3 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
7 - 2018-03-02 2023-06-23 7 5 458526+ennru@users.noreply.... pjfanning@users.noreply.git...
MessageFactory.scala
in reference/src/main/scala/org/apache/pekko/stream/connectors/reference/testkit
 29 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisFirehoseFlow.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/scaladsl
 34 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsPublishFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl
 42 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
LogRotatorSink.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/javadsl
 47 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsSource.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 48 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CapturingAppender.scala
in testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit
 48 4 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CassandraSessionRegistry.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl
 58 5 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GooglePubSub.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/javadsl
 60 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducer.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl
 66 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
DatasetJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 73 5 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CassandraSession.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl
 83 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
100 3 2023-02-20 2023-08-06 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisFlow.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl
 104 6 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
InfluxDbSourceStage.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 115 7 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
WriteMessage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 121 7 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisSourceStage.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl
 130 1 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TableDataJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 140 9 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase
 166 7 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsAckFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 178 4 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 202 11 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 221 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
QueryJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 225 4 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
StorageObject.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 419 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsMessages.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 501 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisSource.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/javadsl
 15 - 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
18 - 2023-01-10 2023-08-06 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CassandraMetricsRegistry.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra
 24 1 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
XmlParsing.scala
in xml/src/main/scala/org/apache/pekko/stream/connectors/xml/javadsl
 30 - 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsConsumer.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl
 45 1 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
OrientDbFlow.scala
in orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/javadsl
 51 - 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Resource.scala
in reference/src/main/scala/org/apache/pekko/stream/connectors/reference
 51 4 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
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
344 1 2016-10-26 2023-08-03 363 102 mmartynas@gmail.com pjfanning@users.noreply.git...
build.sbt
in root
 383 2 2016-05-10 2023-08-06 286 66 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
plugins.sbt
in project
 24 - 2016-05-10 2023-08-06 136 22 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
Common.scala
in project
 95 1 2016-08-11 2023-06-23 75 18 mmartynas@gmail.com pjfanning@users.noreply.git...
41 1 2017-09-18 2023-06-23 13 9 github@bzzt.net pjfanning@users.noreply.git...
7 - 2018-03-02 2023-06-23 7 5 458526+ennru@users.noreply.... pjfanning@users.noreply.git...
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1271 52 2023-03-14 2023-06-23 8 3 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SplitAfterSize.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 56 2 2023-03-14 2023-06-23 4 3 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 936 61 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 655 19 2023-03-14 2023-06-26 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryAvroStorage.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl
 154 4 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryArrowStorage.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl
 163 4 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GCStorage.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/javadsl
 129 2 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryStorage.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl
 105 1 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsPublishFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 95 2 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsPublishSink.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl
 58 - 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQuery.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl
 182 9 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 708 48 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ElasticsearchConnectionSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 78 3 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in reference/src/main/scala/org/apache/pekko/stream/connectors/reference
 68 6 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisSourceStage.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl
 130 1 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisFlow.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl
 104 6 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisFirehoseFlow.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/scaladsl
 34 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
LogRotatorSink.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/javadsl
 47 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 221 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GooglePubSub.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/javadsl
 60 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
StorageObject.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 419 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CapturingAppender.scala
in testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit
 48 4 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsAckFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 178 4 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsSource.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 48 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsPublishFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl
 42 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
InfluxDbSourceStage.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 115 7 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
100 3 2023-02-20 2023-08-06 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TableDataJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 140 9 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 202 11 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
DatasetJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 73 5 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
QueryJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 225 4 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CassandraSessionRegistry.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl
 58 5 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CassandraSession.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl
 83 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducer.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl
 66 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsMessages.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 501 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
WriteMessage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 121 7 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MessageFactory.scala
in reference/src/main/scala/org/apache/pekko/stream/connectors/reference/testkit
 29 - 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase
 166 7 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ShardProcessor.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl
 64 4 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisSource.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/javadsl
 15 - 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3Headers.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 93 5 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ServiceAccountCredentials.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth
 54 2 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AzureQueueSourceStage.scala
in azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/impl
 53 1 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AmqpSourceStage.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl
 144 1 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@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
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 285 9 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PekkoConnectorsResultMapperHelper.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 223 10 2023-05-30 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PdxEncoder.scala
in geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx
 193 5 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
DirectoryChangesSource.java
in file/src/main/java/org/apache/pekko/stream/connectors/file/impl
 165 5 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AndroidConfig.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models
 157 13 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FcmNotificationModels.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 147 3 2023-03-14 2023-06-23 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MqttSessionSettings.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 127 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PdxDecoder.scala
in geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx
 126 4 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ObjectAccessControls.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 124 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryBasicFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 123 17 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file
 122 9 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FileTailSource.java
in file/src/main/java/org/apache/pekko/stream/connectors/file/impl
 110 5 2023-03-14 2023-06-26 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AndroidConfig.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models
 108 5 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Bucket.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 83 2 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 79 5 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ElasticsearchWriteSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 75 3 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ShardSettings.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis
 74 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CsvBench.scala
in csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl
 67 4 2023-03-14 2023-05-16 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CsvToMap.java
in csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl
 63 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
WebConfig.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models
 55 5 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryJavaTimeFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 55 11 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Codec.scala
in ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl
 55 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CsvFormatting.java
in csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl
 51 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsAckGroupedSettings.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 48 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ShardIterator.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis
 47 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryStorageSettings.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage
 46 2 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisFlowSettings.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis
 45 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
package.scala
in slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl
 45 2 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SpringWebPekkoStreamsConfiguration.java
in spring-web/src/main/java/org/apache/pekko/stream/connectors/spring/web
 45 5 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
HBaseCapabilities.scala
in hbase/src/main/scala/org/apache/pekko/stream/connectors/hbase/impl
 45 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisFirehoseFlowSettings.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose
 43 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SigningKey.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth
 42 2 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 41 2 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
LogCapturing.scala
in testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl
 41 2 2023-03-14 2023-06-23 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
41 - 2023-07-28 2023-07-28 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
FcmNotification.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models
 41 2 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ElasticsearchSourceSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 40 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
OpensearchSourceSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 40 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryCollectionFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 39 3 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GeodeSettings.scala
in geode/src/main/scala/org/apache/pekko/stream/connectors/geode
 38 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AcknowledgeMode.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 38 3 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisSchedulerSettings.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis
 36 3 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
LogbackUtil.scala
in testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit
 36 2 2023-03-14 2023-06-23 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsPublishGroupedSettings.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 36 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CassandraWriteSettings.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra
 36 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FileTailSource.java
in file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl
 35 3 2023-03-14 2023-06-26 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
LogCapturingJunit4.scala
in testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/javadsl
 35 1 2023-03-14 2023-06-23 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PekkoStreamsRegistrar.java
in spring-web/src/main/java/org/apache/pekko/stream/connectors/spring/web
 35 3 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
OpensearchWriteSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 35 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryRestBasicFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 33 2 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Correlations

File Size vs. Number of Changes: 642 points

project/plugins.sbt x: 24 lines of code y: 136 # changes build.sbt x: 383 lines of code y: 286 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 465 lines of code y: 4 # changes project/MetaInfLicenseNoticeCopy.scala x: 18 lines of code y: 6 # changes project/CopyrightHeader.scala x: 100 lines of code y: 7 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/Utils.scala x: 13 lines of code y: 3 # changes project/Dependencies.scala x: 344 lines of code y: 363 # changes project/LicenseReport.scala x: 41 lines of code y: 1 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala x: 324 lines of code y: 3 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/SourceSettingsBase.scala x: 37 lines of code y: 4 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 655 lines of code y: 9 # changes file/src/main/java/org/apache/pekko/stream/connectors/file/impl/FileTailSource.java x: 110 lines of code y: 3 # changes file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/FileTailSource.java x: 35 lines of code y: 3 # changes ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqClient.scala x: 190 lines of code y: 5 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala x: 195 lines of code y: 4 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectionProvider.scala x: 311 lines of code y: 6 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectorSettings.scala x: 263 lines of code y: 6 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala x: 149 lines of code y: 3 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpFlowStageLogic.scala x: 48 lines of code y: 3 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpAsyncFlowStage.scala x: 51 lines of code y: 3 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpConnectorLogic.scala x: 60 lines of code y: 6 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpReplyToSinkStage.scala x: 60 lines of code y: 3 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala x: 181 lines of code y: 3 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSimpleFlowStage.scala x: 33 lines of code y: 3 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala x: 144 lines of code y: 6 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpFlowWithContext.scala x: 22 lines of code y: 4 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpSink.scala x: 19 lines of code y: 4 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpSource.scala x: 16 lines of code y: 3 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/model.scala x: 79 lines of code y: 2 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpFlow.scala x: 28 lines of code y: 3 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpRpcFlow.scala x: 25 lines of code y: 3 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/CommittableReadResult.scala x: 10 lines of code y: 3 # changes avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/impl/AvroParquetFlow.scala x: 40 lines of code y: 3 # changes avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/impl/AvroParquetSource.scala x: 32 lines of code y: 3 # changes aws-event-bridge/src/main/scala/org/apache/pekko/stream/connectors/aws/eventbridge/EventBridgePublishSettings.scala x: 15 lines of code y: 2 # changes aws-event-bridge/src/main/scala/org/apache/pekko/stream/connectors/aws/eventbridge/javadsl/EventBridgePublisher.scala x: 50 lines of code y: 3 # changes azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/impl/AzureQueueSourceStage.scala x: 53 lines of code y: 6 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraMetricsRegistry.scala x: 24 lines of code y: 6 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraServerMetaData.scala x: 6 lines of code y: 2 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraWriteSettings.scala x: 36 lines of code y: 2 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CqlSessionProvider.scala x: 59 lines of code y: 3 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/DriverConfigLoaderFromConfig.scala x: 23 lines of code y: 2 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/PekkoDiscoverySessionProvider.scala x: 46 lines of code y: 5 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala x: 83 lines of code y: 7 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionRegistry.scala x: 23 lines of code y: 5 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraFlow.scala x: 72 lines of code y: 6 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSession.scala x: 143 lines of code y: 4 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionRegistry.scala x: 58 lines of code y: 7 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/CouchbaseSessionRegistry.scala x: 56 lines of code y: 5 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionImpl.scala x: 134 lines of code y: 3 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionJavaAdapter.scala x: 82 lines of code y: 4 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/RxUtilities.scala x: 54 lines of code y: 3 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseSession.scala x: 76 lines of code y: 4 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseSource.scala x: 18 lines of code y: 3 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/model.scala x: 166 lines of code y: 7 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala x: 151 lines of code y: 3 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseSession.scala x: 75 lines of code y: 3 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/DiscoverySupport.scala x: 58 lines of code y: 5 # changes csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/ByteOrderMark.java x: 13 lines of code y: 2 # changes csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvFormatting.java x: 51 lines of code y: 2 # changes csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvParsing.java x: 30 lines of code y: 2 # changes csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvToMap.java x: 63 lines of code y: 2 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvFormatter.scala x: 98 lines of code y: 2 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParsingStage.scala x: 53 lines of code y: 2 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala x: 122 lines of code y: 2 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala x: 95 lines of code y: 2 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/ByteOrderMark.scala x: 10 lines of code y: 2 # changes dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala x: 43 lines of code y: 3 # changes elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch/ApiVersionBase.java x: 2 lines of code y: 2 # changes elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch/OpensearchApiVersion.java x: 4 lines of code y: 2 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchConnectionSettings.scala x: 78 lines of code y: 8 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchSourceSettings.scala x: 40 lines of code y: 2 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchWriteSettings.scala x: 75 lines of code y: 2 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchConnectionSettings.scala x: 7 lines of code y: 2 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/WriteMessage.scala x: 121 lines of code y: 7 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/WriteSettingsBase.scala x: 26 lines of code y: 3 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSimpleFlowStage.scala x: 123 lines of code y: 3 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala x: 265 lines of code y: 3 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala x: 123 lines of code y: 6 # changes file/src/main/java/org/apache/pekko/stream/connectors/file/impl/DirectoryChangesSource.java x: 165 lines of code y: 2 # changes file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/Directory.java x: 27 lines of code y: 2 # changes file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/DirectoryChangesSource.java x: 18 lines of code y: 2 # changes file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarArchiveEntry.scala x: 115 lines of code y: 3 # changes file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarReaderStage.scala x: 224 lines of code y: 3 # changes file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveFlow.scala x: 70 lines of code y: 3 # changes file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipReaderSource.scala x: 83 lines of code y: 3 # changes file/src/main/scala/org/apache/pekko/stream/connectors/file/javadsl/LogRotatorSink.scala x: 47 lines of code y: 7 # changes file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/LogRotatorSink.scala x: 165 lines of code y: 3 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/CommonFtpOperations.scala x: 85 lines of code y: 3 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpBrowserGraphStage.scala x: 62 lines of code y: 3 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala x: 292 lines of code y: 3 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala x: 190 lines of code y: 3 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/SftpOperations.scala x: 169 lines of code y: 5 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala x: 313 lines of code y: 5 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala x: 285 lines of code y: 2 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala x: 175 lines of code y: 3 # changes geode/src/main/java/org/apache/pekko/stream/connectors/geode/javadsl/Geode.java x: 44 lines of code y: 3 # changes geode/src/main/scala/org/apache/pekko/stream/connectors/geode/GeodeSettings.scala x: 38 lines of code y: 2 # changes geode/src/main/scala/org/apache/pekko/stream/connectors/geode/PekkoPdxSerializer.scala x: 5 lines of code y: 3 # changes geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/DelegatingPdxSerializer.scala x: 29 lines of code y: 2 # changes geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxDecoder.scala x: 126 lines of code y: 2 # changes geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxEncoder.scala x: 193 lines of code y: 2 # changes geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/ShapelessPdxSerializer.scala x: 21 lines of code y: 2 # changes geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/stage/GeodeCQueryGraphLogic.scala x: 80 lines of code y: 3 # changes google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryStorageSettings.scala x: 46 lines of code y: 2 # changes google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/ProtobufConverters.scala x: 35 lines of code y: 5 # changes google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/AkkaGrpcSettings.scala x: 57 lines of code y: 4 # changes google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/ArrowSource.scala x: 70 lines of code y: 6 # changes google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala x: 163 lines of code y: 9 # changes google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala x: 154 lines of code y: 9 # changes google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala x: 105 lines of code y: 8 # changes google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala x: 92 lines of code y: 4 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala x: 182 lines of code y: 8 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/JobJsonProtocol.scala x: 197 lines of code y: 6 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/QueryJsonProtocol.scala x: 225 lines of code y: 7 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableDataJsonProtocol.scala x: 140 lines of code y: 7 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableJsonProtocol.scala x: 202 lines of code y: 7 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryJobs.scala x: 114 lines of code y: 4 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTableData.scala x: 107 lines of code y: 3 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema/BasicSchemas.scala x: 20 lines of code y: 2 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryRestBasicFormats.scala x: 33 lines of code y: 2 # changes google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala x: 88 lines of code y: 4 # changes google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala x: 231 lines of code y: 3 # changes google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala x: 221 lines of code y: 7 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/Bucket.scala x: 83 lines of code y: 2 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/FailedUpload.scala x: 11 lines of code y: 5 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageAttributes.scala x: 27 lines of code y: 5 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageSettings.scala x: 120 lines of code y: 4 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 419 lines of code y: 7 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala x: 218 lines of code y: 3 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 296 lines of code y: 3 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/javadsl/GCStorage.scala x: 129 lines of code y: 8 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleSettings.scala x: 203 lines of code y: 4 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/Credentials.scala x: 73 lines of code y: 4 # changes google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala x: 213 lines of code y: 5 # changes google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/AndroidConfig.scala x: 108 lines of code y: 2 # changes hbase/src/main/scala/org/apache/pekko/stream/connectors/hbase/HTableSettings.scala x: 49 lines of code y: 5 # changes hbase/src/main/scala/org/apache/pekko/stream/connectors/hbase/impl/HBaseCapabilities.scala x: 45 lines of code y: 2 # changes hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/HdfsFlowStage.scala x: 169 lines of code y: 3 # changes hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/writer/SequenceWriter.scala x: 66 lines of code y: 3 # changes hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/scaladsl/HdfsFlow.scala x: 124 lines of code y: 3 # changes huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettings.scala x: 161 lines of code y: 4 # changes huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/AndroidConfig.scala x: 157 lines of code y: 2 # changes influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl/InfluxDbFlowStage.scala x: 111 lines of code y: 4 # changes influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl/InfluxDbSourceStage.scala x: 115 lines of code y: 7 # changes influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl/PekkoConnectorsResultMapperHelper.scala x: 223 lines of code y: 2 # changes influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/javadsl/InfluxDbFlow.scala x: 51 lines of code y: 6 # changes ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/IronMqSettings.scala x: 96 lines of code y: 3 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/Headers.scala x: 68 lines of code y: 3 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala x: 142 lines of code y: 4 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala x: 501 lines of code y: 7 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsProducerSettings.scala x: 97 lines of code y: 3 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala x: 332 lines of code y: 4 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala x: 103 lines of code y: 3 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumer.scala x: 45 lines of code y: 6 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducer.scala x: 66 lines of code y: 7 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsConsumer.scala x: 62 lines of code y: 6 # changes kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSourceStage.scala x: 130 lines of code y: 7 # changes kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisSource.scala x: 15 lines of code y: 6 # changes kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisFlow.scala x: 104 lines of code y: 7 # changes kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/KinesisFirehoseFlowSettings.scala x: 43 lines of code y: 2 # changes kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/scaladsl/KinesisFirehoseFlow.scala x: 34 lines of code y: 7 # changes mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoSource.scala x: 9 lines of code y: 3 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttSessionSettings.scala x: 127 lines of code y: 2 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala x: 608 lines of code y: 3 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala x: 808 lines of code y: 3 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala x: 708 lines of code y: 8 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala x: 572 lines of code y: 3 # changes mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/settings.scala x: 211 lines of code y: 6 # changes orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/impl/OrientDbFlowStage.scala x: 100 lines of code y: 3 # changes orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/impl/OrientDbSourceStage.scala x: 92 lines of code y: 6 # changes pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaSettings.scala x: 436 lines of code y: 4 # changes pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableSource.scala x: 127 lines of code y: 3 # changes pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableWriteFlow.scala x: 118 lines of code y: 4 # changes project/AutomaticModuleName.scala x: 7 lines of code y: 7 # changes project/Common.scala x: 95 lines of code y: 75 # changes project/TestChanged.scala x: 41 lines of code y: 13 # changes reference/src/main/scala/org/apache/pekko/stream/connectors/reference/model.scala x: 68 lines of code y: 8 # changes reference/src/main/scala/org/apache/pekko/stream/connectors/reference/testkit/MessageFactory.scala x: 29 lines of code y: 7 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala x: 305 lines of code y: 4 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/Marshalling.scala x: 259 lines of code y: 4 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 1271 lines of code y: 8 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala x: 936 lines of code y: 9 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala x: 417 lines of code y: 4 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/settings.scala x: 499 lines of code y: 4 # changes simple-codecs/src/main/scala/org/apache/pekko/stream/connectors/recordio/impl/RecordIOFramingStage.scala x: 90 lines of code y: 3 # changes slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala x: 138 lines of code y: 5 # changes solr/src/main/scala/org/apache/pekko/stream/connectors/solr/impl/SolrFlowStage.scala x: 160 lines of code y: 6 # changes solr/src/main/scala/org/apache/pekko/stream/connectors/solr/javadsl/SolrFlow.scala x: 95 lines of code y: 6 # changes sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsSourceSettings.scala x: 128 lines of code y: 5 # changes sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala x: 42 lines of code y: 7 # changes sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishSink.scala x: 58 lines of code y: 8 # changes sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala x: 178 lines of code y: 7 # changes sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala x: 95 lines of code y: 8 # changes text/src/main/scala/org/apache/pekko/stream/connectors/text/impl/CharsetLogic.scala x: 136 lines of code y: 3 # changes unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala x: 429 lines of code y: 3 # changes xml/src/main/scala/org/apache/pekko/stream/connectors/xml/javadsl/XmlParsing.scala x: 30 lines of code y: 6 # changes xml/src/main/scala/org/apache/pekko/stream/connectors/xml/model.scala x: 124 lines of code y: 6 # changes csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala x: 67 lines of code y: 2 # changes mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala x: 101 lines of code y: 2 # changes mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala x: 113 lines of code y: 2 # changes
363.0
# changes
  min: 1.0
  average: 4.7
  25th percentile: 3.0
  median: 3.0
  75th percentile: 4.0
  max: 363.0
0 1271.0
lines of code
min: 2.0 | average: 68.79 | 25th percentile: 19.0 | median: 38.5 | 75th percentile: 71.25 | max: 1271.0

Number of Contributors vs. Number of Changes: 642 points

project/plugins.sbt x: 22 # contributors y: 136 # changes build.sbt x: 66 # contributors y: 286 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 2 # contributors y: 4 # changes project/MetaInfLicenseNoticeCopy.scala x: 2 # contributors y: 6 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/Utils.scala x: 1 # contributors y: 3 # changes project/Dependencies.scala x: 102 # contributors y: 363 # changes project/LicenseReport.scala x: 1 # contributors y: 1 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 2 # contributors y: 9 # changes ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqClient.scala x: 2 # contributors y: 5 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/model.scala x: 1 # contributors y: 2 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvFormatter.scala x: 2 # contributors y: 2 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchConnectionSettings.scala x: 2 # contributors y: 8 # changes project/AutomaticModuleName.scala x: 5 # contributors y: 7 # changes project/Common.scala x: 18 # contributors y: 75 # changes project/TestChanged.scala x: 9 # contributors y: 13 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 3 # contributors y: 8 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/SplitAfterSize.scala x: 3 # contributors y: 4 # changes
363.0
# changes
  min: 1.0
  average: 4.7
  25th percentile: 3.0
  median: 3.0
  75th percentile: 4.0
  max: 363.0
0 102.0
# contributors
min: 1.0 | average: 2.1 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.0 | max: 102.0

Number of Contributors vs. File Size: 642 points

project/plugins.sbt x: 22 # contributors y: 24 lines of code build.sbt x: 66 # contributors y: 383 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 2 # contributors y: 465 lines of code project/MetaInfLicenseNoticeCopy.scala x: 2 # contributors y: 18 lines of code project/CopyrightHeader.scala x: 2 # contributors y: 100 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/Utils.scala x: 1 # contributors y: 13 lines of code project/Dependencies.scala x: 102 # contributors y: 344 lines of code project/LicenseReport.scala x: 1 # contributors y: 41 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala x: 2 # contributors y: 324 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/SourceSettingsBase.scala x: 2 # contributors y: 37 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 2 # contributors y: 655 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/impl/FileTailSource.java x: 1 # contributors y: 110 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/FileTailSource.java x: 1 # contributors y: 35 lines of code ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqClient.scala x: 2 # contributors y: 190 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala x: 2 # contributors y: 195 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectionProvider.scala x: 2 # contributors y: 311 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectorSettings.scala x: 2 # contributors y: 263 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala x: 2 # contributors y: 149 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpFlowStageLogic.scala x: 2 # contributors y: 48 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpAsyncFlowStage.scala x: 2 # contributors y: 51 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpConnectorLogic.scala x: 2 # contributors y: 60 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala x: 2 # contributors y: 181 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSimpleFlowStage.scala x: 2 # contributors y: 33 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala x: 2 # contributors y: 144 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpFlowWithContext.scala x: 2 # contributors y: 22 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/CommittableReadResult.scala x: 2 # contributors y: 15 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/model.scala x: 1 # contributors y: 79 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpFlow.scala x: 2 # contributors y: 28 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/CommittableReadResult.scala x: 2 # contributors y: 10 lines of code azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/model.scala x: 1 # contributors y: 16 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraServerMetaData.scala x: 1 # contributors y: 6 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraWriteSettings.scala x: 1 # contributors y: 36 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/DriverConfigLoaderFromConfig.scala x: 1 # contributors y: 23 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala x: 2 # contributors y: 83 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraFlow.scala x: 2 # contributors y: 72 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionImpl.scala x: 2 # contributors y: 134 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseSession.scala x: 2 # contributors y: 76 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/model.scala x: 2 # contributors y: 166 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala x: 2 # contributors y: 151 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvFormatting.java x: 1 # contributors y: 51 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvParsing.java x: 1 # contributors y: 30 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvQuotingStyle.java x: 1 # contributors y: 5 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvToMap.java x: 1 # contributors y: 63 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala x: 2 # contributors y: 122 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala x: 2 # contributors y: 95 lines of code dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala x: 2 # contributors y: 43 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchWriteSettings.scala x: 1 # contributors y: 75 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/impl/DirectoryChangesSource.java x: 1 # contributors y: 165 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarArchiveEntry.scala x: 2 # contributors y: 115 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarReaderStage.scala x: 2 # contributors y: 224 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveFlow.scala x: 2 # contributors y: 70 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/model.scala x: 1 # contributors y: 122 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/LogRotatorSink.scala x: 2 # contributors y: 165 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpBrowserGraphStage.scala x: 2 # contributors y: 62 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala x: 2 # contributors y: 292 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala x: 1 # contributors y: 285 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala x: 2 # contributors y: 175 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxDecoder.scala x: 1 # contributors y: 126 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxEncoder.scala x: 1 # contributors y: 193 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryStorageSettings.scala x: 1 # contributors y: 46 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala x: 2 # contributors y: 105 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/JobJsonProtocol.scala x: 2 # contributors y: 197 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableDataJsonProtocol.scala x: 2 # contributors y: 140 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableJsonProtocol.scala x: 2 # contributors y: 202 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryQueries.scala x: 2 # contributors y: 109 lines of code google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala x: 2 # contributors y: 88 lines of code google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala x: 2 # contributors y: 231 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/Bucket.scala x: 1 # contributors y: 83 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageSettings.scala x: 2 # contributors y: 120 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 2 # contributors y: 419 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala x: 2 # contributors y: 218 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 2 # contributors y: 296 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/javadsl/GCStorage.scala x: 2 # contributors y: 129 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmNotificationModels.scala x: 1 # contributors y: 147 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala x: 2 # contributors y: 213 lines of code huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/AndroidConfig.scala x: 1 # contributors y: 157 lines of code influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl/PekkoConnectorsResultMapperHelper.scala x: 1 # contributors y: 223 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala x: 2 # contributors y: 501 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala x: 2 # contributors y: 332 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala x: 2 # contributors y: 608 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala x: 2 # contributors y: 808 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala x: 2 # contributors y: 708 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala x: 2 # contributors y: 572 lines of code pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaSettings.scala x: 2 # contributors y: 436 lines of code project/AutomaticModuleName.scala x: 5 # contributors y: 7 lines of code project/Common.scala x: 18 # contributors y: 95 lines of code project/TestChanged.scala x: 9 # contributors y: 41 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala x: 2 # contributors y: 305 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/Marshalling.scala x: 2 # contributors y: 259 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 3 # contributors y: 1271 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/SplitAfterSize.scala x: 3 # contributors y: 56 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala x: 2 # contributors y: 936 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/settings.scala x: 2 # contributors y: 499 lines of code solr/src/main/scala/org/apache/pekko/stream/connectors/solr/impl/SolrFlowStage.scala x: 2 # contributors y: 160 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala x: 2 # contributors y: 178 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala x: 2 # contributors y: 429 lines of code csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala x: 1 # contributors y: 67 lines of code
1271.0
lines of code
  min: 2.0
  average: 68.79
  25th percentile: 19.0
  median: 38.5
  75th percentile: 71.25
  max: 1271.0
0 102.0
# contributors
min: 1.0 | average: 2.1 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.0 | max: 102.0