apache / 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 715 files with 49,713 lines of code.
    • 3 files changed more than 100 times (882 lines of code)
    • 1 file changed 51-100 times (101 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 93 files changed 6-20 times (14,570 lines of code)
    • 618 files changed 1-5 times (34,160 lines of code)
1% | <1% | 0% | 29% | 68%
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 715 files with 49,713 lines of code.
    • 2 files changed by more than 25 contributors (863 lines of code)
    • 2 files changed by 11-25 contributors (120 lines of code)
    • 1 file changed by 6-10 contributors (40 lines of code)
    • 520 files changed by 2-5 contributors (41,298 lines of code)
    • 190 files changed by 1 contributor (7,392 lines of code)
1% | <1% | <1% | 83% | 14%
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, yaml, txt, sh, pub, sbt, json, svg, properties, gitattributes, gitignore
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% | 30% | 68%
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
project57% | 12% | 0% | 21% | 8%
ROOT100% | 0% | 0% | 0% | 0%
s30% | 0% | 0% | 57% | 42%
ftp0% | 0% | 0% | 64% | 35%
google-cloud-storage0% | 0% | 0% | 61% | 38%
jms0% | 0% | 0% | 39% | 60%
google-cloud-bigquery0% | 0% | 0% | 45% | 54%
amqp0% | 0% | 0% | 46% | 53%
mqtt-streaming0% | 0% | 0% | 19% | 80%
sqs0% | 0% | 0% | 47% | 52%
google-cloud-pub-sub0% | 0% | 0% | 86% | 13%
unix-domain-socket0% | 0% | 0% | 86% | 13%
google-cloud-bigquery-storage0% | 0% | 0% | 48% | 51%
google-common0% | 0% | 0% | 30% | 69%
kinesis0% | 0% | 0% | 44% | 55%
elasticsearch0% | 0% | 0% | 25% | 74%
solr0% | 0% | 0% | 60% | 39%
cassandra0% | 0% | 0% | 34% | 65%
couchbase0% | 0% | 0% | 20% | 79%
mqtt0% | 0% | 0% | 26% | 73%
influxdb0% | 0% | 0% | 24% | 75%
xml0% | 0% | 0% | 24% | 75%
reference0% | 0% | 0% | 38% | 61%
orientdb0% | 0% | 0% | 30% | 69%
slick0% | 0% | 0% | 51% | 48%
mongodb0% | 0% | 0% | 45% | 54%
kudu0% | 0% | 0% | 32% | 67%
azure-storage-queue0% | 0% | 0% | 24% | 75%
testkit0% | 0% | 0% | 26% | 73%
file0% | 0% | 0% | 3% | 96%
jakartams0% | 0% | 0% | 0% | 100%
pravega0% | 0% | 0% | 0% | 100%
google-fcm0% | 0% | 0% | 0% | 100%
mqttv50% | 0% | 0% | 0% | 100%
csv0% | 0% | 0% | 0% | 100%
geode0% | 0% | 0% | 0% | 100%
huawei-push-kit0% | 0% | 0% | 0% | 100%
hdfs0% | 0% | 0% | 0% | 100%
ironmq0% | 0% | 0% | 0% | 100%
aws-spi-pekko-http0% | 0% | 0% | 0% | 100%
couchbase30% | 0% | 0% | 0% | 100%
google-cloud-pub-sub-grpc0% | 0% | 0% | 0% | 100%
udp0% | 0% | 0% | 0% | 100%
hbase0% | 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%
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
437 1 2016-10-26 2025-05-07 422 112 mmartynas@gmail.com pjfanning@users.noreply.git...
build.sbt
in root
 426 2 2016-05-10 2025-04-23 323 69 patrik.nordwall@gmail.com sndnv@users.noreply.github.com
plugins.sbt
in project
 19 - 2016-05-10 2024-11-14 157 25 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
Common.scala
in project
 101 1 2016-08-11 2024-03-22 80 18 mmartynas@gmail.com pjfanning@users.noreply.git...
40 1 2017-09-18 2024-02-25 14 10 github@bzzt.net 35491928+laglangyue@users.n...
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1288 52 2023-03-14 2024-02-09 12 3 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 659 19 2023-03-14 2023-11-12 11 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
ResumableUpload.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 163 5 2023-03-14 2024-09-14 10 4 pjfanning@users.noreply.git... mdedetrich@gmail.com
22 - 2023-01-10 2024-06-02 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ElasticsearchConnectionSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 77 3 2023-03-14 2024-01-01 9 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
SqsPublishFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 96 2 2023-03-14 2024-08-06 9 3 pjfanning@users.noreply.git... llazanja96@gmail.com
TableDataJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 141 9 2023-03-14 2023-06-23 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...
BigQuery.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl
 188 9 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl
 313 20 2023-03-14 2024-06-03 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 712 48 2023-03-14 2023-06-23 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...
LogRotatorSink.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/javadsl
 46 4 2023-03-14 2023-06-23 8 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 2024-04-29 8 3 pjfanning@users.noreply.git... 35491928+laglangyue@users.n...
FtpsOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 48 2 2023-03-14 2024-06-03 8 3 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ServiceAccountCredentials.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth
 52 2 2023-03-14 2024-01-14 8 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
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...
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 8 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 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisSchedulerSourceStage.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl
 95 5 2023-03-14 2024-02-09 8 3 pjfanning@users.noreply.git... jtjeferreira@gmail.com
KinesisFlow.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl
 104 6 2023-03-14 2023-12-28 8 3 pjfanning@users.noreply.git... jtjeferreira@gmail.com
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...
model.scala
in couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase
 167 7 2023-03-14 2023-06-23 8 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
 203 11 2023-03-14 2023-06-23 8 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
 222 21 2023-03-14 2024-01-14 8 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
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 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 298 16 2023-03-14 2025-04-23 8 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 327 9 2023-03-14 2024-06-03 8 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 2025-04-07 8 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
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...
FtpLike.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 39 3 2023-03-14 2024-06-03 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...
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...
AzureQueueSourceStage.scala
in azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/impl
 53 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GoogleOAuth2.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth
 53 2 2023-03-14 2024-01-27 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...
Credentials.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth
 78 4 2023-03-14 2024-01-14 7 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
100 3 2023-02-20 2023-08-06 7 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
437 1 2016-10-26 2025-05-07 422 112 mmartynas@gmail.com pjfanning@users.noreply.git...
build.sbt
in root
 426 2 2016-05-10 2025-04-23 323 69 patrik.nordwall@gmail.com sndnv@users.noreply.github.com
plugins.sbt
in project
 19 - 2016-05-10 2024-11-14 157 25 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
Common.scala
in project
 101 1 2016-08-11 2024-03-22 80 18 mmartynas@gmail.com pjfanning@users.noreply.git...
40 1 2017-09-18 2024-02-25 14 10 github@bzzt.net 35491928+laglangyue@users.n...
7 - 2018-03-02 2023-06-23 7 5 458526+ennru@users.noreply.... pjfanning@users.noreply.git...
ResumableUpload.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 163 5 2023-03-14 2024-09-14 10 4 pjfanning@users.noreply.git... mdedetrich@gmail.com
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1288 52 2023-03-14 2024-02-09 12 3 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
SqsPublishFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 96 2 2023-03-14 2024-08-06 9 3 pjfanning@users.noreply.git... llazanja96@gmail.com
StorageObject.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 419 2 2023-03-14 2025-04-07 8 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 298 16 2023-03-14 2025-04-23 8 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
FtpsOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 48 2 2023-03-14 2024-06-03 8 3 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 2024-04-29 8 3 pjfanning@users.noreply.git... 35491928+laglangyue@users.n...
KinesisFlow.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl
 104 6 2023-03-14 2023-12-28 8 3 pjfanning@users.noreply.git... jtjeferreira@gmail.com
KinesisSchedulerSourceStage.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl
 95 5 2023-03-14 2024-02-09 8 3 pjfanning@users.noreply.git... jtjeferreira@gmail.com
AmqpConnectorSettings.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 289 13 2023-03-14 2024-06-24 7 3 pjfanning@users.noreply.git... diogomoura13@gmail.com
AmqpSourceStage.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl
 148 1 2023-03-14 2024-06-24 7 3 pjfanning@users.noreply.git... diogomoura13@gmail.com
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 439 6 2023-03-14 2024-07-07 6 3 pjfanning@users.noreply.git... arnout@bzzt.net
GoogleHttp.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http
 119 6 2023-03-14 2025-03-30 6 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
AmqpRpcFlowStage.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl
 192 1 2023-03-14 2024-06-24 5 3 pjfanning@users.noreply.git... diogomoura13@gmail.com
AmqpReplyToSinkStage.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl
 64 1 2023-03-14 2024-06-24 5 3 pjfanning@users.noreply.git... diogomoura13@gmail.com
AmqpSimpleFlowStage.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl
 37 1 2023-03-14 2024-06-24 5 3 pjfanning@users.noreply.git... diogomoura13@gmail.com
BigQueryTableData.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl
 105 4 2023-03-14 2024-01-28 5 3 pjfanning@users.noreply.git... hepin1989@gmail.com
KinesisSchedulerSource.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl
 50 1 2023-03-14 2023-08-21 5 3 pjfanning@users.noreply.git... jtjeferreira@gmail.com
AnnotateLast.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/util
 39 4 2023-03-14 2024-01-28 4 3 pjfanning@users.noreply.git... hepin1989@gmail.com
TextFlow.scala
in text/src/main/scala/org/apache/pekko/stream/connectors/text/scaladsl
 16 - 2023-03-14 2024-06-21 4 3 pjfanning@users.noreply.git... 35491928+laglangyue@users.n...
TextFlow.scala
in text/src/main/scala/org/apache/pekko/stream/connectors/text/javadsl
 15 - 2023-03-14 2024-06-21 4 3 pjfanning@users.noreply.git... 35491928+laglangyue@users.n...
AbstractAmqpAsyncFlowStageLogic.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl
 153 11 2023-03-14 2024-06-24 4 3 pjfanning@users.noreply.git... diogomoura13@gmail.com
KuduClientExt.scala
in kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu
 20 - 2023-03-14 2024-04-23 4 3 pjfanning@users.noreply.git... 35491928+laglangyue@users.n...
UdpBind.scala
in udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl
 78 5 2023-03-14 2025-03-31 4 3 pjfanning@users.noreply.git... 46769049+sdeigm@users.norep...
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...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 659 19 2023-03-14 2023-11-12 11 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 712 48 2023-03-14 2023-06-23 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...
TableDataJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 141 9 2023-03-14 2023-06-23 9 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
 188 9 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
22 - 2023-01-10 2024-06-02 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ElasticsearchConnectionSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 77 3 2023-03-14 2024-01-01 9 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl
 313 20 2023-03-14 2024-06-03 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...
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...
ServiceAccountCredentials.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth
 52 2 2023-03-14 2024-01-14 8 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 203 11 2023-03-14 2023-06-23 8 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 8 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 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
LogRotatorSink.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/javadsl
 46 4 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 327 9 2023-03-14 2024-06-03 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase
 167 7 2023-03-14 2023-06-23 8 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
MqttFlowStage.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl
 429 18 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
settings.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5
 330 5 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
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...
CouchbaseFlow.scala
in couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl
 166 17 2024-05-06 2024-05-06 1 1 35491928+laglangyue@users.n... 35491928+laglangyue@users.n...
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...
JmsConsumerSettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 142 2 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
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...
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...
LegacyFtpsClient.java
in ftp/src/main/java/org/apache/commons/net/ftp
 121 4 2024-06-03 2024-06-03 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SourceStageLogic.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 115 6 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
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...
CouchbaseFlow.scala
in couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/javadsl
 105 - 2024-05-06 2024-05-06 1 1 35491928+laglangyue@users.n... 35491928+laglangyue@users.n...
CouchbaseSource.scala
in couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl
 103 5 2024-05-06 2024-05-06 1 1 35491928+laglangyue@users.n... 35491928+laglangyue@users.n...
S3ITTest.scala
in aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/s3
 102 1 2024-06-12 2024-06-12 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducerSettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 97 2 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
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...
JmsBrowseSettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 77 2 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
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...
KinesisITTest.scala
in aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/kinesis
 72 2 2024-06-12 2024-06-12 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MqttFlowStageWithAck.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl
 72 3 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
CouchbaseSource.scala
in couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/javadsl
 69 1 2024-05-06 2024-05-06 1 1 35491928+laglangyue@users.n... 35491928+laglangyue@users.n...
Headers.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 68 9 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
CsvBench.scala
in csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl
 64 4 2023-03-14 2023-10-30 4 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...
DynamoDBITTest.scala
in aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/dynamodb
 62 1 2024-06-12 2024-06-12 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SendRetrySettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 58 2 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
JwtSprayJson.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/jwt
 56 3 2023-06-08 2024-04-12 4 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...
BigQueryCollectionFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 47 3 2023-03-14 2023-06-23 3 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 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5
 47 2 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
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...
MqttFlow.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl
 46 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
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...
Credentials.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 45 3 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
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...
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...
SQSITTest.scala
in aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/sqs
 44 1 2024-06-12 2024-06-12 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Correlations

File Size vs. Number of Changes: 715 points

project/Dependencies.scala x: 437 lines of code y: 422 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 298 lines of code y: 8 # changes build.sbt x: 426 lines of code y: 323 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala x: 429 lines of code y: 1 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala x: 72 lines of code y: 1 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala x: 36 lines of code y: 1 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala x: 19 lines of code y: 1 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala x: 16 lines of code y: 1 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala x: 26 lines of code y: 1 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala x: 47 lines of code y: 1 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala x: 46 lines of code y: 1 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala x: 22 lines of code y: 1 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala x: 330 lines of code y: 1 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 419 lines of code y: 8 # changes udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl/UdpBind.scala x: 78 lines of code y: 4 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttp.scala x: 119 lines of code y: 6 # changes slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl/SlickWithTryResult.scala x: 34 lines of code y: 1 # changes project/PekkoCoreDependency.scala x: 6 lines of code y: 6 # changes project/plugins.sbt x: 19 lines of code y: 157 # changes project/PekkoHttpDependency.scala x: 6 lines of code y: 4 # changes aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala x: 202 lines of code y: 3 # changes aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/RequestRunner.scala x: 52 lines of code y: 3 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/ResumableUpload.scala x: 163 lines of code y: 10 # changes sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala x: 96 lines of code y: 9 # changes sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsSourceSettings.scala x: 128 lines of code y: 6 # changes geode/src/main/scala-3/org/apache/pekko/stream/connectors/geode/impl/pdx/LabelledGenericGeneric.scala x: 37 lines of code y: 2 # changes unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala x: 439 lines of code y: 6 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala x: 62 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala x: 66 lines of code y: 2 # changes jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConnectorState.java x: 10 lines of code y: 1 # changes jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConsumerControl.java x: 7 lines of code y: 1 # changes jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsProducerStatus.java x: 6 lines of code y: 1 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/ConnectionRetrySettings.scala x: 70 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Destinations.scala x: 30 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Envelopes.scala x: 16 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala x: 501 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsSettings.scala x: 13 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConnector.scala x: 332 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConsumerStage.scala x: 47 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsInternalMatValues.scala x: 10 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducer.scala x: 103 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala x: 60 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsProducerStage.scala x: 203 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/Sessions.scala x: 88 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SoftReferenceCache.scala x: 26 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConsumer.scala x: 45 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsConnectorState.scala x: 33 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsConsumer.scala x: 63 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsProducer.scala x: 49 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/package.scala x: 22 lines of code y: 2 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/AcknowledgeMode.scala x: 38 lines of code y: 1 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Headers.scala x: 68 lines of code y: 1 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsBrowseSettings.scala x: 77 lines of code y: 1 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala x: 142 lines of code y: 1 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsProducerSettings.scala x: 97 lines of code y: 1 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/SendRetrySettings.scala x: 58 lines of code y: 1 # changes jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SourceStageLogic.scala x: 115 lines of code y: 1 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectorSettings.scala x: 289 lines of code y: 7 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala x: 153 lines of code y: 4 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpReplyToSinkStage.scala x: 64 lines of code y: 5 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala x: 192 lines of code y: 5 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSimpleFlowStage.scala x: 37 lines of code y: 5 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala x: 148 lines of code y: 7 # changes text/src/main/scala/org/apache/pekko/stream/connectors/text/javadsl/TextFlow.scala x: 15 lines of code y: 4 # changes aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/dynamodb/DynamoDBITTest.scala x: 62 lines of code y: 1 # changes aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/s3/S3ITTest.scala x: 102 lines of code y: 1 # changes aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/sqs/SQSITTest.scala x: 44 lines of code y: 1 # changes ftp/src/main/java/org/apache/commons/net/ftp/LegacyFtpsClient.java x: 121 lines of code y: 1 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpLike.scala x: 39 lines of code y: 7 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala x: 196 lines of code y: 6 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpsOperations.scala x: 48 lines of code y: 8 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala x: 313 lines of code y: 9 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala x: 327 lines of code y: 8 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala x: 175 lines of code y: 7 # changes project/MetaInfLicenseNoticeCopy.scala x: 22 lines of code y: 9 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/DiskBuffer.scala x: 72 lines of code y: 4 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/Signer.scala x: 54 lines of code y: 4 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/package.scala x: 30 lines of code y: 4 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala x: 122 lines of code y: 3 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala x: 95 lines of code y: 3 # 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: 5 # changes file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveFlow.scala x: 69 lines of code y: 4 # changes couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/Document.scala x: 12 lines of code y: 1 # changes couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/javadsl/CouchbaseFlow.scala x: 105 lines of code y: 1 # changes couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/javadsl/CouchbaseSink.scala x: 40 lines of code y: 1 # changes couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl/CouchbaseFlow.scala x: 166 lines of code y: 1 # changes couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl/CouchbaseSource.scala x: 103 lines of code y: 1 # changes testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala x: 41 lines of code y: 4 # changes kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/KuduClientExt.scala x: 20 lines of code y: 4 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/jwt/JwtSprayJson.scala x: 56 lines of code y: 4 # changes project/Common.scala x: 101 lines of code y: 80 # changes slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala x: 135 lines of code y: 6 # changes project/TestChanged.scala x: 40 lines of code y: 14 # changes kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala x: 95 lines of code y: 8 # changes kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisSchedulerSource.scala x: 50 lines of code y: 5 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala x: 332 lines of code y: 6 # changes solr/src/main/scala/org/apache/pekko/stream/connectors/solr/impl/SolrFlowStage.scala x: 163 lines of code y: 7 # changes mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala x: 297 lines of code y: 4 # changes mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/settings.scala x: 211 lines of code y: 7 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 1288 lines of code y: 12 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/ComputeEngineCredentials.scala x: 24 lines of code y: 4 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/Credentials.scala x: 78 lines of code y: 7 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpGraphStageLogic.scala x: 55 lines of code y: 5 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala x: 292 lines of code y: 5 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTableData.scala x: 105 lines of code y: 5 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/util/AnnotateLast.scala x: 39 lines of code y: 4 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchConnectionSettings.scala x: 77 lines of code y: 9 # changes google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala x: 222 lines of code y: 8 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/GoogleOAuth2.scala x: 53 lines of code y: 7 # changes mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala x: 101 lines of code y: 3 # changes mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala x: 113 lines of code y: 3 # changes kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisFlow.scala x: 104 lines of code y: 8 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 659 lines of code y: 11 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala x: 417 lines of code y: 5 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 466 lines of code y: 5 # changes csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala x: 64 lines of code y: 4 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/WriteSettingsBase.scala x: 23 lines of code y: 4 # changes geode/src/main/scala-2/org/apache/pekko/stream/connectors/geode/impl/pdx/ObjectDecoder.scala x: 28 lines of code y: 1 # changes geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxEncoder.scala x: 172 lines of code y: 3 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/CanonicalRequest.scala x: 75 lines of code y: 5 # changes json-streaming/src/main/scala/org/apache/pekko/stream/connectors/json/impl/JsonStreamReader.scala x: 57 lines of code y: 5 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpBrowserGraphStage.scala x: 62 lines of code y: 4 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpDirectoryOperationsGraphStage.scala x: 26 lines of code y: 4 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpOperations.scala x: 44 lines of code y: 4 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/SftpOperations.scala x: 169 lines of code y: 6 # changes google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala x: 94 lines of code y: 5 # changes google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GrpcSubscriber.scala x: 45 lines of code y: 4 # changes google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala x: 47 lines of code y: 4 # changes amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectionProvider.scala x: 315 lines of code y: 7 # changes google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala x: 233 lines of code y: 6 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala x: 224 lines of code y: 6 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala x: 712 lines of code y: 9 # changes mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala x: 572 lines of code y: 4 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/RestBulkApi.scala x: 50 lines of code y: 4 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala x: 202 lines of code y: 5 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/SourceStageLogic.scala x: 115 lines of code y: 4 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchFlow.scala x: 137 lines of code y: 4 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/DatasetJsonProtocol.scala x: 73 lines of code y: 8 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/ErrorProtoJsonProtocol.scala x: 37 lines of code y: 4 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/JobJsonProtocol.scala x: 200 lines of code y: 7 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/QueryJsonProtocol.scala x: 225 lines of code y: 8 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableDataJsonProtocol.scala x: 141 lines of code y: 9 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableJsonProtocol.scala x: 203 lines of code y: 8 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleSettings.scala x: 205 lines of code y: 5 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryException.scala x: 60 lines of code y: 5 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala x: 188 lines of code y: 9 # changes google-common/src/main/java/org/apache/pekko/stream/connectors/google/javadsl/XUploadContentType.java x: 9 lines of code y: 3 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/javadsl/Google.scala x: 32 lines of code y: 5 # changes google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmSender.scala x: 45 lines of code y: 5 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/model.scala x: 167 lines of code y: 8 # changes couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala x: 154 lines of code y: 4 # changes cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala x: 83 lines of code y: 8 # changes file/src/main/scala/org/apache/pekko/stream/connectors/file/javadsl/LogRotatorSink.scala x: 46 lines of code y: 8 # changes file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/LogRotatorSink.scala x: 165 lines of code y: 4 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryQueries.scala x: 110 lines of code y: 4 # changes google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTables.scala x: 60 lines of code y: 4 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/GoogleOAuth2Credentials.scala x: 34 lines of code y: 4 # changes google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmJsonSupport.scala x: 66 lines of code y: 4 # changes google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala x: 218 lines of code y: 4 # changes huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitJsonSupport.scala x: 193 lines of code y: 4 # changes ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqPullStage.scala x: 86 lines of code y: 4 # changes project/CopyrightHeader.scala x: 100 lines of code y: 7 # changes csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala x: 324 lines of code y: 3 # changes file/src/main/java/org/apache/pekko/stream/connectors/file/impl/FileTailSource.java x: 110 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 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/AmqpRpcFlow.scala x: 25 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 avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/scaladsl/AvroParquetFlow.scala x: 10 lines of code y: 4 # changes avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/scaladsl/AvroParquetSink.scala x: 12 lines of code y: 4 # 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/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/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/CouchbaseSink.scala x: 39 lines of code y: 3 # 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/scaladsl/CouchbaseSession.scala x: 75 lines of code y: 3 # 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/scaladsl/CsvParsing.scala x: 20 lines of code y: 3 # changes dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala x: 43 lines of code y: 3 # changes dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/javadsl/DynamoDb.scala x: 48 lines of code y: 5 # 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/WriteMessage.scala x: 121 lines of code y: 7 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSimpleFlowStage.scala x: 124 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/ElasticsearchFlow.scala x: 73 lines of code y: 6 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala x: 123 lines of code y: 6 # changes elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchSource.scala x: 81 lines of code y: 3 # 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/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/ZipReaderSource.scala x: 83 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 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/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryAttributes.scala x: 17 lines of code y: 4 # changes google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/javadsl/GooglePubSub.scala x: 60 lines of code y: 7 # 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/javadsl/GCStorage.scala x: 129 lines of code y: 8 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/OAuth2Credentials.scala x: 58 lines of code y: 3 # changes google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmNotificationModels.scala x: 147 lines of code y: 3 # 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 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/model.scala x: 106 lines of code y: 4 # 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/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: 52 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/JmsMessages.scala x: 501 lines of code y: 7 # 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/ShardSettings.scala x: 74 lines of code y: 2 # 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/kinesisfirehose/scaladsl/KinesisFirehoseFlow.scala x: 34 lines of code y: 7 # changes mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl/MongoFlow.scala x: 66 lines of code y: 6 # 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 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/PravegaFlow.scala x: 94 lines of code y: 4 # changes pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableReadFlow.scala x: 102 lines of code y: 4 # 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 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/model.scala x: 936 lines of code y: 9 # 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 solr/src/main/scala/org/apache/pekko/stream/connectors/solr/SolrMessages.scala x: 99 lines of code y: 6 # 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/scaladsl/SqsAckFlow.scala x: 178 lines of code y: 7 # changes text/src/main/scala/org/apache/pekko/stream/connectors/text/impl/CharsetLogic.scala x: 136 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
422.0
# changes
  min: 1.0
  average: 4.82
  25th percentile: 2.0
  median: 3.0
  75th percentile: 4.0
  max: 422.0
0 1288.0
lines of code
min: 2.0 | average: 69.53 | 25th percentile: 19.0 | median: 39.0 | 75th percentile: 72.0 | max: 1288.0

Number of Contributors vs. Number of Changes: 715 points

project/Dependencies.scala x: 112 # contributors y: 422 # changes google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 3 # contributors y: 8 # changes build.sbt x: 69 # contributors y: 323 # changes mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala x: 1 # contributors y: 1 # changes udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl/UdpBind.scala x: 3 # contributors y: 4 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttp.scala x: 3 # contributors y: 6 # changes project/PekkoCoreDependency.scala x: 1 # contributors y: 6 # changes project/plugins.sbt x: 25 # contributors y: 157 # changes project/PekkoHttpDependency.scala x: 2 # contributors y: 4 # changes aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala x: 2 # contributors y: 3 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/ResumableUpload.scala x: 4 # contributors y: 10 # changes sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala x: 3 # contributors y: 9 # changes sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsSourceSettings.scala x: 2 # contributors y: 6 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpLike.scala x: 2 # contributors y: 7 # changes ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala x: 2 # contributors y: 9 # changes google-common/src/main/scala/org/apache/pekko/stream/connectors/google/jwt/JwtSprayJson.scala x: 1 # contributors y: 4 # changes project/Common.scala x: 18 # contributors y: 80 # changes project/TestChanged.scala x: 10 # contributors y: 14 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 3 # contributors y: 12 # changes s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 2 # contributors y: 11 # changes jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/GraphStageCompanion.scala x: 1 # contributors y: 2 # changes project/AutomaticModuleName.scala x: 5 # contributors y: 7 # changes
422.0
# changes
  min: 1.0
  average: 4.82
  25th percentile: 2.0
  median: 3.0
  75th percentile: 4.0
  max: 422.0
0 112.0
# contributors
min: 1.0 | average: 2.09 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 112.0

Number of Contributors vs. File Size: 715 points

project/Dependencies.scala x: 112 # contributors y: 437 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 3 # contributors y: 298 lines of code build.sbt x: 69 # contributors y: 426 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala x: 1 # contributors y: 429 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala x: 1 # contributors y: 72 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala x: 1 # contributors y: 36 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala x: 1 # contributors y: 19 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala x: 1 # contributors y: 26 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala x: 1 # contributors y: 47 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala x: 1 # contributors y: 15 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala x: 1 # contributors y: 22 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala x: 1 # contributors y: 330 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 3 # contributors y: 419 lines of code udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl/UdpBind.scala x: 3 # contributors y: 78 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttp.scala x: 3 # contributors y: 119 lines of code slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl/SlickWithTryResult.scala x: 1 # contributors y: 34 lines of code project/PekkoCoreDependency.scala x: 1 # contributors y: 6 lines of code project/plugins.sbt x: 25 # contributors y: 19 lines of code project/PekkoHttpDependency.scala x: 2 # contributors y: 6 lines of code aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala x: 2 # contributors y: 202 lines of code aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/RequestRunner.scala x: 2 # contributors y: 52 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/ResumableUpload.scala x: 4 # contributors y: 163 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala x: 3 # contributors y: 96 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsSourceSettings.scala x: 2 # contributors y: 128 lines of code geode/src/main/scala-3/org/apache/pekko/stream/connectors/geode/impl/pdx/LabelledGenericGeneric.scala x: 2 # contributors y: 37 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala x: 3 # contributors y: 439 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala x: 2 # contributors y: 62 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala x: 2 # contributors y: 66 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Destinations.scala x: 2 # contributors y: 30 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Envelopes.scala x: 2 # contributors y: 16 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala x: 2 # contributors y: 501 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsSettings.scala x: 2 # contributors y: 13 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConnector.scala x: 2 # contributors y: 332 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConsumerStage.scala x: 2 # contributors y: 47 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducer.scala x: 2 # contributors y: 103 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala x: 2 # contributors y: 60 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsProducerStage.scala x: 2 # contributors y: 203 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/Sessions.scala x: 2 # contributors y: 88 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConsumer.scala x: 2 # contributors y: 45 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsConnectorState.scala x: 2 # contributors y: 33 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/package.scala x: 2 # contributors y: 22 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Credentials.scala x: 1 # contributors y: 45 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Headers.scala x: 1 # contributors y: 68 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsBrowseSettings.scala x: 1 # contributors y: 77 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala x: 1 # contributors y: 142 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsProducerSettings.scala x: 1 # contributors y: 97 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/SendRetrySettings.scala x: 1 # contributors y: 58 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SourceStageLogic.scala x: 1 # contributors y: 115 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectorSettings.scala x: 3 # contributors y: 289 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala x: 3 # contributors y: 153 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpReplyToSinkStage.scala x: 3 # contributors y: 64 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala x: 3 # contributors y: 192 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSimpleFlowStage.scala x: 3 # contributors y: 37 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala x: 3 # contributors y: 148 lines of code text/src/main/scala/org/apache/pekko/stream/connectors/text/javadsl/TextFlow.scala x: 3 # contributors y: 15 lines of code text/src/main/scala/org/apache/pekko/stream/connectors/text/scaladsl/TextFlow.scala x: 3 # contributors y: 16 lines of code aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/dynamodb/DynamoDBITTest.scala x: 1 # contributors y: 62 lines of code aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/s3/S3ITTest.scala x: 1 # contributors y: 102 lines of code ftp/src/main/java/org/apache/commons/net/ftp/LegacyFtpsClient.java x: 1 # contributors y: 121 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala x: 2 # contributors y: 196 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpsOperations.scala x: 3 # contributors y: 48 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala x: 2 # contributors y: 313 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala x: 2 # contributors y: 327 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala x: 2 # contributors y: 175 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/DiskBuffer.scala x: 2 # contributors y: 72 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 couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl/CouchbaseFlow.scala x: 1 # contributors y: 166 lines of code project/Common.scala x: 18 # contributors y: 101 lines of code slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala x: 2 # contributors y: 135 lines of code project/TestChanged.scala x: 10 # contributors y: 40 lines of code solr/src/main/scala/org/apache/pekko/stream/connectors/solr/impl/SolrFlowStage.scala x: 2 # contributors y: 163 lines of code mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala x: 2 # contributors y: 297 lines of code mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/settings.scala x: 2 # contributors y: 211 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 3 # contributors y: 1288 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/Credentials.scala x: 2 # contributors y: 78 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala x: 2 # contributors y: 292 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTableData.scala x: 3 # contributors y: 105 lines of code google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala x: 2 # contributors y: 222 lines of code mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala x: 2 # contributors y: 101 lines of code mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala x: 2 # contributors y: 113 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 2 # contributors y: 659 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala x: 2 # contributors y: 417 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 2 # contributors y: 466 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxEncoder.scala x: 2 # contributors y: 172 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectionProvider.scala x: 2 # contributors y: 315 lines of code google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala x: 2 # contributors y: 233 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala x: 2 # contributors y: 224 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala x: 2 # contributors y: 712 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 elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchFlow.scala x: 2 # contributors y: 137 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala x: 2 # contributors y: 188 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala x: 2 # contributors y: 154 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala x: 2 # contributors y: 83 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryQueries.scala x: 2 # contributors y: 110 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala x: 2 # contributors y: 218 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala x: 2 # contributors y: 324 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/impl/FileTailSource.java x: 1 # contributors y: 110 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSession.scala x: 2 # contributors y: 143 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/CsvQuotingStyle.java x: 1 # contributors y: 5 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/WriteMessage.scala x: 2 # contributors y: 121 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala x: 2 # contributors y: 265 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/model.scala x: 1 # contributors y: 122 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 huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettings.scala x: 2 # contributors y: 161 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 mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttSessionSettings.scala x: 1 # contributors y: 127 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 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 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/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 sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala x: 2 # contributors y: 178 lines of code
1288.0
lines of code
  min: 2.0
  average: 69.53
  25th percentile: 19.0
  median: 39.0
  75th percentile: 72.0
  max: 1288.0
0 112.0
# contributors
min: 1.0 | average: 2.09 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 112.0