apache / incubator-pekko-connectors
File Size

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

Intro
Learn more...
File Size Overall
2% | 10% | 21% | 21% | 42%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
scala2% | 11% | 21% | 21% | 42%
sbt0% | 0% | 94% | 0% | 5%
java0% | 0% | 0% | 32% | 67%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
s324% | 31% | 28% | 2% | 12%
mqtt-streaming0% | 75% | 12% | 3% | 8%
jms0% | 18% | 12% | 20% | 47%
google-cloud-storage0% | 0% | 53% | 21% | 24%
ftp0% | 0% | 49% | 29% | 20%
amqp0% | 0% | 34% | 28% | 37%
mqtt0% | 0% | 63% | 0% | 36%
google-cloud-pub-sub0% | 0% | 76% | 0% | 23%
pravega0% | 0% | 37% | 38% | 24%
google-fcm0% | 0% | 36% | 21% | 41%
unix-domain-socket0% | 0% | 76% | 0% | 23%
google-cloud-bigquery0% | 0% | 19% | 43% | 37%
ROOT0% | 0% | 100% | 0% | 0%
project0% | 0% | 50% | 0% | 49%
csv0% | 0% | 32% | 12% | 54%
elasticsearch0% | 0% | 16% | 31% | 51%
file0% | 0% | 15% | 46% | 37%
influxdb0% | 0% | 32% | 33% | 34%
sqs0% | 0% | 17% | 26% | 56%
google-common0% | 0% | 14% | 19% | 66%
hdfs0% | 0% | 0% | 61% | 38%
huawei-push-kit0% | 0% | 0% | 54% | 45%
couchbase0% | 0% | 0% | 40% | 59%
google-cloud-bigquery-storage0% | 0% | 0% | 41% | 58%
geode0% | 0% | 0% | 37% | 62%
kinesis0% | 0% | 0% | 23% | 76%
xml0% | 0% | 0% | 36% | 63%
mqtt-streaming-bench0% | 0% | 0% | 100% | 0%
ironmq0% | 0% | 0% | 26% | 73%
solr0% | 0% | 0% | 27% | 72%
cassandra0% | 0% | 0% | 21% | 78%
slick0% | 0% | 0% | 59% | 40%
text0% | 0% | 0% | 66% | 33%
google-cloud-pub-sub-grpc0% | 0% | 0% | 0% | 100%
orientdb0% | 0% | 0% | 0% | 100%
reference0% | 0% | 0% | 0% | 100%
mongodb0% | 0% | 0% | 0% | 100%
udp0% | 0% | 0% | 0% | 100%
hbase0% | 0% | 0% | 0% | 100%
azure-storage-queue0% | 0% | 0% | 0% | 100%
kudu0% | 0% | 0% | 0% | 100%
testkit0% | 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%
Longest Files (Top 50)
File# lines# units
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1271 52
model.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 936 61
ServerState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 808 10
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 708 48
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 655 19
ClientState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 608 8
MqttSession.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl
 572 13
JmsMessages.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 501 21
settings.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 499 19
RequestState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 465 11
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 429 6
StorageObject.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 419 2
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl
 417 5
build.sbt
in root
 383 2
344 1
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22
CsvParser.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 324 11
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl
 313 20
AmqpConnectionProvider.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 311 15
HttpRequests.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 305 15
MqttFlowStage.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl
 298 17
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 296 16
FtpIOGraphStage.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 292 5
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 285 9
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11
AmqpConnectorSettings.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 263 13
Marshalling.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 259 -
PubSubApi.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl
 231 14
QueryJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 225 4
TarReaderStage.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive
 224 1
PekkoConnectorsResultMapperHelper.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 223 10
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 221 21
Formats.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 218 8
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl
 218 17
FcmSettings.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 213 12
settings.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt
 211 3
GoogleSettings.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 203 12
SqsModel.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 203 21
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 202 11
JobJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 197 15
JmsProducerStage.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 195 4
PdxEncoder.scala
in geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx
 193 5
PushKitJsonSupport.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl
 193 10
FtpSourceFactory.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 190 10
IronMqClient.scala
in ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl
 190 10
BigQuery.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl
 182 9
AmqpRpcFlowStage.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl
 181 1
SqsAckFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 178 4
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl
 175 5
Files With Most Units (Top 50)
File# lines# units
model.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 936 61
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1271 52
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 708 48
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 221 21
SqsModel.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 203 21
JmsMessages.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 501 21
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl
 313 20
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 655 19
settings.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 499 19
LogRotatorSink.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl
 165 17
BigQueryBasicFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 123 17
MqttFlowStage.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl
 298 17
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl
 218 17
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 296 16
HttpRequests.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 305 15
AmqpConnectionProvider.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 311 15
model.scala
in xml/src/main/scala/org/apache/pekko/stream/connectors/xml
 124 15
JobJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 197 15
PubSubApi.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl
 231 14
CassandraSession.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl
 143 14
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13
AndroidConfig.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models
 157 13
AmqpConnectorSettings.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 263 13
MqttSession.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl
 572 13
GoogleSettings.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 203 12
HdfsFlowStage.scala
in hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl
 169 12
FcmSettings.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 213 12
HmsSettings.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit
 161 11
AbstractAmqpAsyncFlowStageLogic.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl
 149 11
BigQueryJavaTimeFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 55 11
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 202 11
CsvParser.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 324 11
RequestState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 465 11
CharsetLogic.scala
in text/src/main/scala/org/apache/pekko/stream/connectors/text/impl
 136 11
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11
FtpSourceFactory.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 190 10
ServerSideEncryption.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/headers
 121 10
PushKitJsonSupport.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl
 193 10
PekkoConnectorsResultMapperHelper.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 223 10
ServerState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 808 10
IronMqClient.scala
in ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl
 190 10
CouchbaseFlow.scala
in couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl
 151 10
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 285 9
model.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file
 122 9
BigQuery.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl
 182 9
TableDataJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 140 9
Headers.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 68 9
CommonFtpOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 85 8
SftpOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 169 8
Files With Long Lines (Top 49)

There are 49 files with lines longer than 120 characters. In total, there are 105 long lines.

File# lines# units# long lines
DynamoDbOp.scala
in dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb
 43 2 18
build.sbt
in root
 383 2 13
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13 6
BigQueryBasicFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 123 17 6
TarReaderStage.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive
 224 1 5
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl
 218 17 4
ShardSettings.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis
 74 1 2
FtpOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 41 2 2
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1271 52 2
PubSubApi.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl
 231 14 2
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 221 21 2
LogCapturing.scala
in testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl
 41 2 2
SqsAckGroupedSettings.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 48 1 2
BigQueryRestBasicFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 33 2 2
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 708 48 2
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl
 64 6 2
KinesisFirehoseFlowSettings.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose
 43 1 1
SftpOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 169 8 1
FtpsOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 36 2 1
HttpRequests.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 305 15 1
settings.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 499 19 1
PekkoGrpcSettings.scala
in google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/impl
 34 1 1
TarArchiveEntry.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive
 115 6 1
PushKitJsonSupport.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl
 193 10 1
settings.scala
in azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue
 30 1 1
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 296 16 1
LogCapturingJunit4.scala
in testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/javadsl
 35 1 1
BigQueryAvroStorage.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl
 76 1 1
BigQueryArrowStorage.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl
 76 1 1
BalancingMapAsync.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/impl
 95 2 1
SqsPublishGroupedSettings.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 36 1 1
SqsAckFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 178 4 1
SqsSourceSettings.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 128 3 1
StreamingXmlParser.scala
in xml/src/main/scala/org/apache/pekko/stream/connectors/xml/impl
 94 1 1
PekkoConnectorsResultMapperHelper.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 223 10 1
Common.scala
in project
 95 1 1
PekkoDiscoverySessionProvider.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra
 46 2 1
CsvParser.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 324 11 1
authors.scala
in scripts
 45 - 1
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 429 6 1
MqttSessionSettings.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 127 1 1
KuduTableSettings.scala
in kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu
 47 1 1
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22 1
AcknowledgeMode.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 38 3 1
FcmSettings.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 213 12 1
ElasticsearchSourceSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 40 1 1
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11 1
WriteMessage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 121 7 1
OpensearchSourceSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 40 1 1
Correlations

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

project/plugins.sbt x: 157 commits (all time) y: 24 lines of code build.sbt x: 391 commits (all time) y: 383 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 4 commits (all time) y: 465 lines of code project/MetaInfLicenseNoticeCopy.scala x: 7 commits (all time) y: 18 lines of code project/CopyrightHeader.scala x: 7 commits (all time) y: 100 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/Utils.scala x: 3 commits (all time) y: 13 lines of code project/Dependencies.scala x: 518 commits (all time) y: 344 lines of code project/LicenseReport.scala x: 1 commits (all time) y: 41 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala x: 3 commits (all time) y: 324 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/SourceSettingsBase.scala x: 4 commits (all time) y: 37 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 9 commits (all time) y: 655 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/impl/FileTailSource.java x: 3 commits (all time) y: 110 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/FileTailSource.java x: 3 commits (all time) y: 35 lines of code ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqClient.scala x: 5 commits (all time) y: 190 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala x: 4 commits (all time) y: 195 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectionProvider.scala x: 6 commits (all time) y: 311 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectorSettings.scala x: 6 commits (all time) y: 263 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala x: 3 commits (all time) y: 149 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpFlowStageLogic.scala x: 3 commits (all time) y: 48 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpAsyncFlowStage.scala x: 3 commits (all time) y: 51 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpAsyncUnorderedFlowStage.scala x: 3 commits (all time) y: 37 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpConnectorLogic.scala x: 6 commits (all time) y: 60 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpReplyToSinkStage.scala x: 3 commits (all time) y: 60 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala x: 3 commits (all time) y: 181 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala x: 6 commits (all time) y: 144 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpFlowWithContext.scala x: 4 commits (all time) y: 22 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpSink.scala x: 4 commits (all time) y: 19 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpSource.scala x: 3 commits (all time) y: 16 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/CommittableReadResult.scala x: 4 commits (all time) y: 15 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/model.scala x: 2 commits (all time) y: 79 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpFlow.scala x: 3 commits (all time) y: 28 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpRpcFlow.scala x: 3 commits (all time) y: 25 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/CommittableReadResult.scala x: 3 commits (all time) y: 10 lines of code avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/scaladsl/AvroParquetFlow.scala x: 4 commits (all time) y: 10 lines of code aws-event-bridge/src/main/scala/org/apache/pekko/stream/connectors/aws/eventbridge/EventBridgePublishSettings.scala x: 2 commits (all time) y: 15 lines of code azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/impl/AzureQueueSourceStage.scala x: 6 commits (all time) y: 53 lines of code azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue/model.scala x: 2 commits (all time) y: 16 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraMetricsRegistry.scala x: 6 commits (all time) y: 24 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraServerMetaData.scala x: 2 commits (all time) y: 6 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/CassandraWriteSettings.scala x: 2 commits (all time) y: 36 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/DriverConfigLoaderFromConfig.scala x: 2 commits (all time) y: 23 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/PekkoDiscoverySessionProvider.scala x: 5 commits (all time) y: 46 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala x: 7 commits (all time) y: 83 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionRegistry.scala x: 5 commits (all time) y: 23 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraFlow.scala x: 6 commits (all time) y: 72 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSession.scala x: 4 commits (all time) y: 143 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionRegistry.scala x: 7 commits (all time) y: 58 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/CouchbaseSessionRegistry.scala x: 5 commits (all time) y: 56 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionImpl.scala x: 3 commits (all time) y: 134 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionJavaAdapter.scala x: 4 commits (all time) y: 82 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/javadsl/CouchbaseSession.scala x: 4 commits (all time) y: 76 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/model.scala x: 7 commits (all time) y: 166 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala x: 3 commits (all time) y: 151 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseSession.scala x: 3 commits (all time) y: 75 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvFormatting.java x: 2 commits (all time) y: 51 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvParsing.java x: 2 commits (all time) y: 30 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvQuotingStyle.java x: 2 commits (all time) y: 5 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvToMap.java x: 2 commits (all time) y: 63 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvFormatter.scala x: 2 commits (all time) y: 98 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala x: 2 commits (all time) y: 122 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala x: 2 commits (all time) y: 95 lines of code dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala x: 3 commits (all time) y: 43 lines of code dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/scaladsl/DynamoDb.scala x: 4 commits (all time) y: 43 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchConnectionSettings.scala x: 8 commits (all time) y: 78 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchWriteSettings.scala x: 2 commits (all time) y: 75 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/OpensearchWriteSettings.scala x: 2 commits (all time) y: 35 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/WriteMessage.scala x: 7 commits (all time) y: 121 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSimpleFlowStage.scala x: 3 commits (all time) y: 123 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl/ElasticsearchSourceStage.scala x: 3 commits (all time) y: 265 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/javadsl/ElasticsearchSource.scala x: 6 commits (all time) y: 123 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchSource.scala x: 3 commits (all time) y: 81 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/testkit/MessageFactory.scala x: 4 commits (all time) y: 35 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/impl/DirectoryChangesSource.java x: 2 commits (all time) y: 165 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarArchiveEntry.scala x: 3 commits (all time) y: 115 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarReaderStage.scala x: 3 commits (all time) y: 224 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveFlow.scala x: 3 commits (all time) y: 70 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/javadsl/LogRotatorSink.scala x: 7 commits (all time) y: 47 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/LogRotatorSink.scala x: 3 commits (all time) y: 165 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpBrowserGraphStage.scala x: 3 commits (all time) y: 62 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala x: 3 commits (all time) y: 292 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpOperations.scala x: 2 commits (all time) y: 41 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala x: 3 commits (all time) y: 190 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/SftpOperations.scala x: 5 commits (all time) y: 169 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala x: 5 commits (all time) y: 313 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala x: 2 commits (all time) y: 285 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala x: 3 commits (all time) y: 175 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/PekkoPdxSerializer.scala x: 3 commits (all time) y: 5 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxDecoder.scala x: 2 commits (all time) y: 126 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxEncoder.scala x: 2 commits (all time) y: 193 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/stage/GeodeCQueryGraphLogic.scala x: 3 commits (all time) y: 80 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryStorageSettings.scala x: 2 commits (all time) y: 46 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/ProtobufConverters.scala x: 5 commits (all time) y: 35 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/AkkaGrpcSettings.scala x: 4 commits (all time) y: 57 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/ArrowSource.scala x: 6 commits (all time) y: 70 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala x: 9 commits (all time) y: 163 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala x: 9 commits (all time) y: 154 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala x: 8 commits (all time) y: 105 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala x: 4 commits (all time) y: 92 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala x: 8 commits (all time) y: 182 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/DatasetJsonProtocol.scala x: 7 commits (all time) y: 73 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/JobJsonProtocol.scala x: 6 commits (all time) y: 197 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/QueryJsonProtocol.scala x: 7 commits (all time) y: 225 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableDataJsonProtocol.scala x: 7 commits (all time) y: 140 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableJsonProtocol.scala x: 7 commits (all time) y: 202 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryJobs.scala x: 4 commits (all time) y: 114 lines of code google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/PubSubSettings.scala x: 4 commits (all time) y: 61 lines of code google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala x: 4 commits (all time) y: 88 lines of code google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala x: 3 commits (all time) y: 231 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/Bucket.scala x: 2 commits (all time) y: 83 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/FailedUpload.scala x: 5 commits (all time) y: 11 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageAttributes.scala x: 5 commits (all time) y: 27 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageSettings.scala x: 4 commits (all time) y: 120 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 7 commits (all time) y: 419 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala x: 3 commits (all time) y: 218 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 3 commits (all time) y: 296 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/javadsl/GCStorage.scala x: 8 commits (all time) y: 129 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleSettings.scala x: 4 commits (all time) y: 203 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/Credentials.scala x: 4 commits (all time) y: 73 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttp.scala x: 3 commits (all time) y: 117 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala x: 5 commits (all time) y: 213 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/javadsl/GoogleFcm.scala x: 4 commits (all time) y: 28 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/models/AndroidConfig.scala x: 2 commits (all time) y: 108 lines of code hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/HdfsFlowStage.scala x: 3 commits (all time) y: 169 lines of code hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/model.scala x: 4 commits (all time) y: 106 lines of code huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettings.scala x: 4 commits (all time) y: 161 lines of code huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitJsonSupport.scala x: 3 commits (all time) y: 193 lines of code huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/AndroidConfig.scala x: 2 commits (all time) y: 157 lines of code influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl/InfluxDbSourceStage.scala x: 7 commits (all time) y: 115 lines of code influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl/PekkoConnectorsResultMapperHelper.scala x: 2 commits (all time) y: 223 lines of code ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/IronMqSettings.scala x: 3 commits (all time) y: 96 lines of code ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqPullStage.scala x: 3 commits (all time) y: 86 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala x: 7 commits (all time) y: 501 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala x: 4 commits (all time) y: 332 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala x: 3 commits (all time) y: 103 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsConsumer.scala x: 6 commits (all time) y: 45 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl/JmsProducer.scala x: 7 commits (all time) y: 66 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/scaladsl/JmsConsumer.scala x: 6 commits (all time) y: 62 lines of code kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSourceStage.scala x: 7 commits (all time) y: 130 lines of code kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/javadsl/KinesisSource.scala x: 6 commits (all time) y: 15 lines of code kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisFlow.scala x: 7 commits (all time) y: 104 lines of code kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose/scaladsl/KinesisFirehoseFlow.scala x: 7 commits (all time) y: 34 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala x: 3 commits (all time) y: 608 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala x: 3 commits (all time) y: 808 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala x: 9 commits (all time) y: 708 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/Mqtt.scala x: 4 commits (all time) y: 47 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala x: 3 commits (all time) y: 572 lines of code mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/settings.scala x: 6 commits (all time) y: 211 lines of code orientdb/src/main/scala/org/apache/pekko/stream/connectors/orientdb/impl/OrientDbSourceStage.scala x: 6 commits (all time) y: 92 lines of code pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaSettings.scala x: 4 commits (all time) y: 436 lines of code pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableReadFlow.scala x: 4 commits (all time) y: 102 lines of code pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/impl/PravegaTableSource.scala x: 3 commits (all time) y: 127 lines of code project/AutomaticModuleName.scala x: 7 commits (all time) y: 7 lines of code project/Common.scala x: 96 commits (all time) y: 95 lines of code project/TestChanged.scala x: 15 commits (all time) y: 41 lines of code reference/src/main/scala/org/apache/pekko/stream/connectors/reference/model.scala x: 8 commits (all time) y: 68 lines of code reference/src/main/scala/org/apache/pekko/stream/connectors/reference/testkit/MessageFactory.scala x: 7 commits (all time) y: 29 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala x: 4 commits (all time) y: 305 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/Marshalling.scala x: 4 commits (all time) y: 259 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 9 commits (all time) y: 1271 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala x: 9 commits (all time) y: 936 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala x: 4 commits (all time) y: 417 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/settings.scala x: 4 commits (all time) y: 499 lines of code slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala x: 5 commits (all time) y: 138 lines of code solr/src/main/scala/org/apache/pekko/stream/connectors/solr/SolrMessages.scala x: 6 commits (all time) y: 99 lines of code solr/src/main/scala/org/apache/pekko/stream/connectors/solr/impl/SolrFlowStage.scala x: 6 commits (all time) y: 160 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsModel.scala x: 3 commits (all time) y: 203 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsSourceSettings.scala x: 5 commits (all time) y: 128 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/impl/BalancingMapAsync.scala x: 3 commits (all time) y: 95 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala x: 7 commits (all time) y: 42 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishSink.scala x: 8 commits (all time) y: 58 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala x: 7 commits (all time) y: 178 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala x: 8 commits (all time) y: 95 lines of code text/src/main/scala/org/apache/pekko/stream/connectors/text/impl/CharsetLogic.scala x: 3 commits (all time) y: 136 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala x: 3 commits (all time) y: 429 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/javadsl/UnixDomainSocket.scala x: 4 commits (all time) y: 67 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/scaladsl/UnixDomainSocket.scala x: 4 commits (all time) y: 55 lines of code xml/src/main/scala/org/apache/pekko/stream/connectors/xml/javadsl/XmlParsing.scala x: 6 commits (all time) y: 30 lines of code csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala x: 2 commits (all time) y: 67 lines of code mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala x: 2 commits (all time) y: 101 lines of code mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala x: 2 commits (all time) y: 113 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 518.0
commits (all time)
min: 1.0 | average: 5.18 | 25th percentile: 3.0 | median: 3.0 | 75th percentile: 4.0 | max: 518.0

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

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

File Size vs. Commits (30 days): 8 points

project/plugins.sbt x: 7 commits (30d) y: 24 lines of code build.sbt x: 7 commits (30d) y: 383 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 1 commits (30d) y: 465 lines of code project/MetaInfLicenseNoticeCopy.scala x: 3 commits (30d) y: 18 lines of code project/CopyrightHeader.scala x: 2 commits (30d) y: 100 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/Utils.scala x: 1 commits (30d) y: 13 lines of code project/Dependencies.scala x: 4 commits (30d) y: 344 lines of code project/LicenseReport.scala x: 1 commits (30d) y: 41 lines of code
465.0
lines of code
  min: 13.0
  average: 173.5
  25th percentile: 19.5
  median: 70.5
  75th percentile: 373.25
  max: 465.0
0 7.0
commits (30d)
min: 1.0 | average: 3.25 | 25th percentile: 1.0 | median: 2.5 | 75th percentile: 6.25 | max: 7.0

File Size vs. Contributors (30 days): 8 points

project/plugins.sbt x: 2 contributors (30d) y: 24 lines of code build.sbt x: 2 contributors (30d) y: 383 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 1 contributors (30d) y: 465 lines of code project/MetaInfLicenseNoticeCopy.scala x: 2 contributors (30d) y: 18 lines of code project/CopyrightHeader.scala x: 2 contributors (30d) y: 100 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/Utils.scala x: 1 contributors (30d) y: 13 lines of code project/Dependencies.scala x: 2 contributors (30d) y: 344 lines of code project/LicenseReport.scala x: 1 contributors (30d) y: 41 lines of code
465.0
lines of code
  min: 13.0
  average: 173.5
  25th percentile: 19.5
  median: 70.5
  75th percentile: 373.25
  max: 465.0
0 2.0
contributors (30d)
min: 1.0 | average: 1.63 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 2.0

File Size vs. Commits (90 days): 638 points

project/plugins.sbt x: 15 commits (90d) y: 24 lines of code build.sbt x: 14 commits (90d) y: 383 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 2 commits (90d) y: 465 lines of code project/MetaInfLicenseNoticeCopy.scala x: 4 commits (90d) y: 18 lines of code project/CopyrightHeader.scala x: 4 commits (90d) y: 100 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/Utils.scala x: 2 commits (90d) y: 13 lines of code project/Dependencies.scala x: 18 commits (90d) y: 344 lines of code project/LicenseReport.scala x: 1 commits (90d) y: 41 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala x: 2 commits (90d) y: 324 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/SourceSettingsBase.scala x: 2 commits (90d) y: 37 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 2 commits (90d) y: 655 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/impl/FileTailSource.java x: 2 commits (90d) y: 110 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/FileTailSource.java x: 2 commits (90d) y: 35 lines of code ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqClient.scala x: 3 commits (90d) y: 190 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala x: 2 commits (90d) y: 195 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectionProvider.scala x: 1 commits (90d) y: 311 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectorSettings.scala x: 1 commits (90d) y: 263 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala x: 1 commits (90d) y: 149 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpFlowStageLogic.scala x: 1 commits (90d) y: 48 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpAsyncFlowStage.scala x: 1 commits (90d) y: 51 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpAsyncUnorderedFlowStage.scala x: 1 commits (90d) y: 37 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpConnectorLogic.scala x: 1 commits (90d) y: 60 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala x: 1 commits (90d) y: 181 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSimpleFlowStage.scala x: 1 commits (90d) y: 33 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala x: 1 commits (90d) y: 144 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpFlowWithContext.scala x: 1 commits (90d) y: 22 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpSink.scala x: 1 commits (90d) y: 19 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/CommittableReadResult.scala x: 1 commits (90d) y: 15 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/model.scala x: 1 commits (90d) y: 79 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpFlow.scala x: 1 commits (90d) y: 28 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/CommittableReadResult.scala x: 1 commits (90d) y: 10 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/PekkoDiscoverySessionProvider.scala x: 2 commits (90d) y: 46 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala x: 1 commits (90d) y: 83 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionRegistry.scala x: 2 commits (90d) y: 23 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraFlow.scala x: 1 commits (90d) y: 72 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionRegistry.scala x: 2 commits (90d) y: 58 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionImpl.scala x: 1 commits (90d) y: 134 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/model.scala x: 1 commits (90d) y: 166 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala x: 1 commits (90d) y: 151 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvQuotingStyle.java x: 1 commits (90d) y: 5 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvToMap.java x: 1 commits (90d) y: 63 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvFormatter.scala x: 1 commits (90d) y: 98 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala x: 1 commits (90d) y: 122 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala x: 1 commits (90d) y: 95 lines of code dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/javadsl/DynamoDb.scala x: 3 commits (90d) y: 48 lines of code dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/scaladsl/DynamoDb.scala x: 2 commits (90d) y: 43 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchConnectionSettings.scala x: 2 commits (90d) y: 78 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/impl/DirectoryChangesSource.java x: 1 commits (90d) y: 165 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarArchiveEntry.scala x: 1 commits (90d) y: 115 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarReaderStage.scala x: 1 commits (90d) y: 224 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveFlow.scala x: 1 commits (90d) y: 70 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala x: 1 commits (90d) y: 292 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala x: 1 commits (90d) y: 190 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala x: 2 commits (90d) y: 313 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala x: 1 commits (90d) y: 285 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala x: 1 commits (90d) y: 175 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/PekkoPdxSerializer.scala x: 2 commits (90d) y: 5 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxDecoder.scala x: 1 commits (90d) y: 126 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxEncoder.scala x: 1 commits (90d) y: 193 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala x: 3 commits (90d) y: 163 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala x: 3 commits (90d) y: 154 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala x: 2 commits (90d) y: 105 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala x: 2 commits (90d) y: 92 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageAttributes.scala x: 2 commits (90d) y: 10 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryAttributes.scala x: 2 commits (90d) y: 17 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala x: 2 commits (90d) y: 182 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/JobJsonProtocol.scala x: 1 commits (90d) y: 197 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableDataJsonProtocol.scala x: 1 commits (90d) y: 140 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableJsonProtocol.scala x: 1 commits (90d) y: 202 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryJobs.scala x: 2 commits (90d) y: 114 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryQueries.scala x: 1 commits (90d) y: 109 lines of code google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/PubSubSettings.scala x: 2 commits (90d) y: 61 lines of code google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala x: 2 commits (90d) y: 88 lines of code google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GooglePubSub.scala x: 2 commits (90d) y: 85 lines of code google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala x: 1 commits (90d) y: 231 lines of code google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala x: 2 commits (90d) y: 221 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageAttributes.scala x: 3 commits (90d) y: 27 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageSettings.scala x: 2 commits (90d) y: 120 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 1 commits (90d) y: 419 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala x: 1 commits (90d) y: 218 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 1 commits (90d) y: 296 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/javadsl/GCStorage.scala x: 2 commits (90d) y: 129 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/Credentials.scala x: 2 commits (90d) y: 73 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttp.scala x: 1 commits (90d) y: 117 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmNotificationModels.scala x: 2 commits (90d) y: 147 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala x: 2 commits (90d) y: 213 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/javadsl/GoogleFcm.scala x: 2 commits (90d) y: 28 lines of code huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/HmsSettings.scala x: 2 commits (90d) y: 161 lines of code huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/AndroidConfig.scala x: 1 commits (90d) y: 157 lines of code ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqPullStage.scala x: 1 commits (90d) y: 86 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala x: 2 commits (90d) y: 142 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala x: 1 commits (90d) y: 501 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala x: 2 commits (90d) y: 332 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala x: 1 commits (90d) y: 103 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala x: 1 commits (90d) y: 608 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala x: 1 commits (90d) y: 808 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala x: 2 commits (90d) y: 708 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala x: 1 commits (90d) y: 572 lines of code mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/settings.scala x: 1 commits (90d) y: 211 lines of code pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaSettings.scala x: 1 commits (90d) y: 436 lines of code project/Common.scala x: 4 commits (90d) y: 95 lines of code reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala x: 3 commits (90d) y: 51 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala x: 1 commits (90d) y: 305 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/Marshalling.scala x: 1 commits (90d) y: 259 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 1 commits (90d) y: 1271 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala x: 1 commits (90d) y: 936 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/settings.scala x: 1 commits (90d) y: 499 lines of code slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala x: 2 commits (90d) y: 138 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala x: 1 commits (90d) y: 178 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala x: 1 commits (90d) y: 429 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/scaladsl/UnixDomainSocket.scala x: 2 commits (90d) y: 55 lines of code
1271.0
lines of code
  min: 2.0
  average: 68.78
  25th percentile: 19.0
  median: 38.0
  75th percentile: 70.25
  max: 1271.0
0 18.0
commits (90d)
min: 1.0 | average: 1.22 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 18.0

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

project/plugins.sbt x: 2 contributors (90d) y: 24 lines of code build.sbt x: 2 contributors (90d) y: 383 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 1 contributors (90d) y: 465 lines of code project/MetaInfLicenseNoticeCopy.scala x: 2 contributors (90d) y: 18 lines of code project/CopyrightHeader.scala x: 2 contributors (90d) y: 100 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/Utils.scala x: 1 contributors (90d) y: 13 lines of code project/Dependencies.scala x: 2 contributors (90d) y: 344 lines of code project/LicenseReport.scala x: 1 contributors (90d) y: 41 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala x: 1 contributors (90d) y: 324 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/SourceSettingsBase.scala x: 1 contributors (90d) y: 37 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 1 contributors (90d) y: 655 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/impl/FileTailSource.java x: 1 contributors (90d) y: 110 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl/FileTailSource.java x: 1 contributors (90d) y: 35 lines of code ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqClient.scala x: 2 contributors (90d) y: 190 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala x: 1 contributors (90d) y: 195 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectionProvider.scala x: 1 contributors (90d) y: 311 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectorSettings.scala x: 1 contributors (90d) y: 263 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala x: 1 contributors (90d) y: 149 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpFlowStageLogic.scala x: 1 contributors (90d) y: 48 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpAsyncFlowStage.scala x: 1 contributors (90d) y: 51 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpConnectorLogic.scala x: 1 contributors (90d) y: 60 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala x: 1 contributors (90d) y: 181 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala x: 1 contributors (90d) y: 144 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpFlowWithContext.scala x: 1 contributors (90d) y: 22 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/javadsl/AmqpSink.scala x: 1 contributors (90d) y: 19 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/model.scala x: 1 contributors (90d) y: 79 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/AmqpFlow.scala x: 1 contributors (90d) y: 28 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl/CommittableReadResult.scala x: 1 contributors (90d) y: 10 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala x: 1 contributors (90d) y: 83 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraFlow.scala x: 1 contributors (90d) y: 72 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/impl/CouchbaseSessionImpl.scala x: 1 contributors (90d) y: 134 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/model.scala x: 1 contributors (90d) y: 166 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala x: 1 contributors (90d) y: 151 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvQuotingStyle.java x: 1 contributors (90d) y: 5 lines of code csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl/CsvToMap.java x: 1 contributors (90d) y: 63 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvFormatter.scala x: 1 contributors (90d) y: 98 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala x: 1 contributors (90d) y: 122 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala x: 1 contributors (90d) y: 95 lines of code file/src/main/java/org/apache/pekko/stream/connectors/file/impl/DirectoryChangesSource.java x: 1 contributors (90d) y: 165 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarArchiveEntry.scala x: 1 contributors (90d) y: 115 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/TarReaderStage.scala x: 1 contributors (90d) y: 224 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveFlow.scala x: 1 contributors (90d) y: 70 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala x: 1 contributors (90d) y: 292 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala x: 1 contributors (90d) y: 190 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala x: 1 contributors (90d) y: 285 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala x: 1 contributors (90d) y: 175 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxDecoder.scala x: 1 contributors (90d) y: 126 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala x: 1 contributors (90d) y: 105 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/JobJsonProtocol.scala x: 1 contributors (90d) y: 197 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableDataJsonProtocol.scala x: 1 contributors (90d) y: 140 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableJsonProtocol.scala x: 1 contributors (90d) y: 202 lines of code google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala x: 1 contributors (90d) y: 88 lines of code google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala x: 1 contributors (90d) y: 231 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageSettings.scala x: 1 contributors (90d) y: 120 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 1 contributors (90d) y: 419 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala x: 1 contributors (90d) y: 218 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 1 contributors (90d) y: 296 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala x: 1 contributors (90d) y: 213 lines of code huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models/AndroidConfig.scala x: 1 contributors (90d) y: 157 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsMessages.scala x: 1 contributors (90d) y: 501 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala x: 1 contributors (90d) y: 332 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ClientState.scala x: 1 contributors (90d) y: 608 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/ServerState.scala x: 1 contributors (90d) y: 808 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala x: 1 contributors (90d) y: 708 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala x: 1 contributors (90d) y: 572 lines of code pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega/PravegaSettings.scala x: 1 contributors (90d) y: 436 lines of code project/Common.scala x: 2 contributors (90d) y: 95 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/HttpRequests.scala x: 1 contributors (90d) y: 305 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/Marshalling.scala x: 1 contributors (90d) y: 259 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 1 contributors (90d) y: 1271 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala x: 1 contributors (90d) y: 936 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/settings.scala x: 1 contributors (90d) y: 499 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsAckFlow.scala x: 1 contributors (90d) y: 178 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala x: 1 contributors (90d) y: 429 lines of code
1271.0
lines of code
  min: 2.0
  average: 68.78
  25th percentile: 19.0
  median: 38.0
  75th percentile: 70.25
  max: 1271.0
0 2.0
contributors (90d)
min: 1.0 | average: 1.01 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0