apache / pekko-connectors
File Size

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

Intro
Learn more...
File Size Overall
2% | 10% | 23% | 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% | 10% | 22% | 21% | 42%
sbt0% | 0% | 95% | 0% | 4%
java0% | 0% | 0% | 39% | 60%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
s325% | 30% | 28% | 2% | 12%
mqtt-streaming0% | 75% | 12% | 3% | 8%
jakartams0% | 18% | 19% | 13% | 48%
jms0% | 18% | 19% | 13% | 48%
google-cloud-storage0% | 0% | 54% | 21% | 24%
ftp0% | 0% | 47% | 33% | 19%
mqttv50% | 0% | 70% | 0% | 29%
amqp0% | 0% | 34% | 28% | 36%
mqtt0% | 0% | 63% | 0% | 36%
google-cloud-pub-sub0% | 0% | 76% | 0% | 23%
unix-domain-socket0% | 0% | 76% | 0% | 23%
project0% | 0% | 54% | 12% | 32%
pravega0% | 0% | 37% | 38% | 24%
google-fcm0% | 0% | 36% | 21% | 41%
google-cloud-bigquery0% | 0% | 19% | 43% | 37%
ROOT0% | 0% | 100% | 0% | 0%
csv0% | 0% | 32% | 12% | 54%
elasticsearch0% | 0% | 16% | 32% | 50%
file0% | 0% | 15% | 46% | 37%
influxdb0% | 0% | 32% | 33% | 34%
google-common0% | 0% | 13% | 18% | 67%
sqs0% | 0% | 17% | 26% | 56%
aws-spi-pekko-http0% | 0% | 35% | 18% | 46%
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%
couchbase30% | 0% | 0% | 70% | 29%
geode0% | 0% | 0% | 28% | 71%
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%
text0% | 0% | 0% | 68% | 31%
slick0% | 0% | 0% | 51% | 48%
orientdb0% | 0% | 0% | 21% | 78%
google-cloud-pub-sub-grpc0% | 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%
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
 1288 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
 712 48
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 659 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
JmsMessages.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 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
 466 11
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 439 6
437 1
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13
MqttFlowStage.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl
 429 18
build.sbt
in root
 426 2
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
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22
JmsConnector.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 332 22
settings.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5
 330 5
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 327 9
CsvParser.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 324 11
AmqpConnectionProvider.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 315 15
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl
 313 20
HttpRequests.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 305 15
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 298 16
MqttFlowStage.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl
 297 17
FtpIOGraphStage.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 292 4
AmqpConnectorSettings.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 289 13
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11
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
 233 14
QueryJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 225 4
Formats.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 224 8
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
 222 21
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
 205 12
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 203 11
JmsProducerStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 203 4
SqsModel.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 203 21
PekkoHttpClient.scala
in aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi
 202 10
JmsProducerStage.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 202 4
JobJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 200 15
FtpSourceFactory.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 196 10
PushKitJsonSupport.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl
 193 10
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
 1288 52
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 712 48
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22
JmsConnector.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 332 22
JmsMessages.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 501 21
JmsMessages.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 501 21
SqsModel.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 203 21
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 222 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
 659 19
settings.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 499 19
MqttFlowStage.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl
 429 18
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl
 218 17
BigQueryBasicFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 123 17
LogRotatorSink.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl
 165 17
MqttFlowStage.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl
 297 17
CouchbaseFlow.scala
in couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl
 166 17
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 298 16
AmqpConnectionProvider.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 315 15
JobJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 200 15
model.scala
in xml/src/main/scala/org/apache/pekko/stream/connectors/xml
 124 15
HttpRequests.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 305 15
CassandraSession.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl
 143 14
PubSubApi.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl
 233 14
AndroidConfig.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models
 157 13
MqttSession.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl
 572 13
AmqpConnectorSettings.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 289 13
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13
FcmSettings.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 213 12
GoogleSettings.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 205 12
HdfsFlowStage.scala
in hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl
 169 12
HmsSettings.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit
 161 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
 466 11
CharsetLogic.scala
in text/src/main/scala/org/apache/pekko/stream/connectors/text/impl
 136 11
AbstractAmqpAsyncFlowStageLogic.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl
 153 11
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 203 11
BigQueryJavaTimeFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 55 11
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11
PushKitJsonSupport.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl
 193 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
PekkoHttpClient.scala
in aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi
 202 10
FtpSourceFactory.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 196 10
PekkoConnectorsResultMapperHelper.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 223 10
CouchbaseFlow.scala
in couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl
 154 10
ServerSideEncryption.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/headers
 121 10
TableDataJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 141 9
BigQuery.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl
 188 9
Files With Long Lines (Top 50)

There are 52 files with lines longer than 120 characters. In total, there are 109 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
 426 2 13
BigQueryBasicFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 123 17 6
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13 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
LegacyFtpsClient.java
in ftp/src/main/java/org/apache/commons/net/ftp
 121 4 3
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl
 66 6 2
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 712 48 2
BigQueryRestBasicFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 33 2 2
FtpOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 44 2 2
LogCapturing.scala
in testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl
 41 2 2
ShardSettings.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis
 74 1 2
SqsAckGroupedSettings.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 48 1 2
PubSubApi.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl
 233 14 2
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1288 52 2
FcmSettings.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 213 12 1
PushKitJsonSupport.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl
 193 10 1
CsvParser.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 324 11 1
MqttSessionSettings.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 127 1 1
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 298 16 1
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 439 6 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
TarArchiveEntry.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive
 115 6 1
settings.scala
in azure-storage-queue/src/main/scala/org/apache/pekko/stream/connectors/azure/storagequeue
 30 1 1
Common.scala
in project
 101 1 1
RequestRunner.scala
in aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi
 52 2 1
AcknowledgeMode.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 38 3 1
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22 1
KuduTableSettings.scala
in kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu
 47 1 1
ElasticsearchSourceSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 40 1 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
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11 1
FtpsOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 48 2 1
SftpOperations.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 169 8 1
PekkoGrpcSettings.scala
in google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/impl
 34 1 1
PekkoConnectorsResultMapperHelper.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 223 10 1
AcknowledgeMode.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 38 3 1
JmsConnector.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 332 22 1
LogCapturingJunit4.scala
in testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/javadsl
 35 1 1
KinesisFirehoseFlowSettings.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose
 43 1 1
StreamingXmlParser.scala
in xml/src/main/scala/org/apache/pekko/stream/connectors/xml/impl
 94 1 1
PekkoDiscoverySessionProvider.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra
 46 2 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
SqsPublishGroupedSettings.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 36 1 1
BalancingMapAsync.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/impl
 95 2 1
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 222 21 1
Correlations

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

project/Dependencies.scala x: 602 commits (all time) y: 437 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 8 commits (all time) y: 298 lines of code build.sbt x: 431 commits (all time) y: 426 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala x: 1 commits (all time) y: 429 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala x: 1 commits (all time) y: 72 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala x: 1 commits (all time) y: 36 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala x: 1 commits (all time) y: 19 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala x: 1 commits (all time) y: 26 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala x: 1 commits (all time) y: 47 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala x: 1 commits (all time) y: 15 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala x: 1 commits (all time) y: 22 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala x: 1 commits (all time) y: 330 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 8 commits (all time) y: 419 lines of code udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl/UdpBind.scala x: 4 commits (all time) y: 78 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttp.scala x: 6 commits (all time) y: 119 lines of code slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl/SlickWithTryResult.scala x: 1 commits (all time) y: 34 lines of code project/PekkoCoreDependency.scala x: 6 commits (all time) y: 6 lines of code project/plugins.sbt x: 179 commits (all time) y: 19 lines of code project/PekkoHttpDependency.scala x: 4 commits (all time) y: 6 lines of code aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/PekkoHttpClient.scala x: 3 commits (all time) y: 202 lines of code aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi/RequestRunner.scala x: 3 commits (all time) y: 52 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/ResumableUpload.scala x: 12 commits (all time) y: 163 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala x: 9 commits (all time) y: 96 lines of code sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/SqsSourceSettings.scala x: 6 commits (all time) y: 128 lines of code geode/src/main/scala-3/org/apache/pekko/stream/connectors/geode/impl/pdx/LabelledGenericGeneric.scala x: 2 commits (all time) y: 37 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl/UnixDomainSocketImpl.scala x: 6 commits (all time) y: 439 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsAckSourceStage.scala x: 2 commits (all time) y: 62 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsTxSourceStage.scala x: 3 commits (all time) y: 66 lines of code jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConnectorState.java x: 1 commits (all time) y: 10 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/ConnectionRetrySettings.scala x: 2 commits (all time) y: 70 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Destinations.scala x: 2 commits (all time) y: 30 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Envelopes.scala x: 2 commits (all time) y: 16 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsMessages.scala x: 2 commits (all time) y: 501 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsSettings.scala x: 2 commits (all time) y: 13 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsBrowseStage.scala x: 2 commits (all time) y: 52 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConnector.scala x: 2 commits (all time) y: 332 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsConsumerStage.scala x: 2 commits (all time) y: 47 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsInternalMatValues.scala x: 2 commits (all time) y: 10 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageProducer.scala x: 2 commits (all time) y: 103 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala x: 2 commits (all time) y: 60 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsProducerStage.scala x: 2 commits (all time) y: 203 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/Sessions.scala x: 2 commits (all time) y: 88 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl/JmsConsumer.scala x: 2 commits (all time) y: 45 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/JmsConnectorState.scala x: 2 commits (all time) y: 33 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl/package.scala x: 2 commits (all time) y: 22 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Credentials.scala x: 1 commits (all time) y: 45 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/Headers.scala x: 1 commits (all time) y: 68 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsBrowseSettings.scala x: 1 commits (all time) y: 77 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsConsumerSettings.scala x: 1 commits (all time) y: 142 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/JmsProducerSettings.scala x: 1 commits (all time) y: 97 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/SendRetrySettings.scala x: 1 commits (all time) y: 58 lines of code jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/SourceStageLogic.scala x: 1 commits (all time) y: 115 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectorSettings.scala x: 7 commits (all time) y: 289 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AbstractAmqpAsyncFlowStageLogic.scala x: 4 commits (all time) y: 153 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpReplyToSinkStage.scala x: 5 commits (all time) y: 64 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpRpcFlowStage.scala x: 5 commits (all time) y: 192 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSimpleFlowStage.scala x: 5 commits (all time) y: 37 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/impl/AmqpSourceStage.scala x: 7 commits (all time) y: 148 lines of code text/src/main/scala/org/apache/pekko/stream/connectors/text/javadsl/TextFlow.scala x: 4 commits (all time) y: 15 lines of code text/src/main/scala/org/apache/pekko/stream/connectors/text/scaladsl/TextFlow.scala x: 4 commits (all time) y: 16 lines of code aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/dynamodb/DynamoDBITTest.scala x: 1 commits (all time) y: 62 lines of code aws-spi-pekko-http/src/it/scala/org/apache/pekko/stream/connectors/awsspi/s3/S3ITTest.scala x: 1 commits (all time) y: 102 lines of code ftp/src/main/java/org/apache/commons/net/ftp/LegacyFtpsClient.java x: 1 commits (all time) y: 121 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpLike.scala x: 7 commits (all time) y: 39 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpSourceFactory.scala x: 6 commits (all time) y: 196 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpsOperations.scala x: 8 commits (all time) y: 48 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl/FtpApi.scala x: 9 commits (all time) y: 313 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/model.scala x: 8 commits (all time) y: 327 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/scaladsl/FtpApi.scala x: 7 commits (all time) y: 175 lines of code project/MetaInfLicenseNoticeCopy.scala x: 10 commits (all time) y: 22 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/DiskBuffer.scala x: 4 commits (all time) y: 72 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/Signer.scala x: 4 commits (all time) y: 54 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/package.scala x: 4 commits (all time) y: 30 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapJavaStage.scala x: 3 commits (all time) y: 122 lines of code csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvToMapStage.scala x: 3 commits (all time) y: 95 lines of code google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala x: 5 commits (all time) y: 92 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipArchiveFlow.scala x: 4 commits (all time) y: 69 lines of code couchbase3/src/main/scala/org/apache/pekko/stream/connectors/couchbase3/scaladsl/CouchbaseFlow.scala x: 1 commits (all time) y: 166 lines of code testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala x: 4 commits (all time) y: 41 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/jwt/JwtSprayJson.scala x: 5 commits (all time) y: 56 lines of code project/Common.scala x: 101 commits (all time) y: 101 lines of code slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala x: 6 commits (all time) y: 135 lines of code project/TestChanged.scala x: 16 commits (all time) y: 40 lines of code kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/impl/KinesisSchedulerSourceStage.scala x: 11 commits (all time) y: 95 lines of code kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisSchedulerSource.scala x: 5 commits (all time) y: 50 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsConnector.scala x: 6 commits (all time) y: 332 lines of code solr/src/main/scala/org/apache/pekko/stream/connectors/solr/impl/SolrFlowStage.scala x: 7 commits (all time) y: 163 lines of code mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl/MqttFlowStage.scala x: 4 commits (all time) y: 297 lines of code mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/settings.scala x: 7 commits (all time) y: 211 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/S3Stream.scala x: 13 commits (all time) y: 1288 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/ComputeEngineCredentials.scala x: 4 commits (all time) y: 24 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/Credentials.scala x: 7 commits (all time) y: 78 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpGraphStageLogic.scala x: 5 commits (all time) y: 55 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpIOGraphStage.scala x: 5 commits (all time) y: 292 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTableData.scala x: 5 commits (all time) y: 105 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/util/AnnotateLast.scala x: 4 commits (all time) y: 39 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/ElasticsearchConnectionSettings.scala x: 9 commits (all time) y: 77 lines of code google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala x: 8 commits (all time) y: 222 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/GoogleOAuth2.scala x: 7 commits (all time) y: 53 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/ServiceAccountCredentials.scala x: 8 commits (all time) y: 52 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmFlows.scala x: 6 commits (all time) y: 63 lines of code mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/MqttPerf.scala x: 3 commits (all time) y: 101 lines of code mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/MqttPerf.scala x: 3 commits (all time) y: 113 lines of code kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis/scaladsl/KinesisFlow.scala x: 8 commits (all time) y: 104 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl/S3.scala x: 11 commits (all time) y: 659 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3.scala x: 5 commits (all time) y: 417 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl/RequestState.scala x: 5 commits (all time) y: 466 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxDecoder.scala x: 3 commits (all time) y: 104 lines of code geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx/PdxEncoder.scala x: 3 commits (all time) y: 172 lines of code s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl/auth/CanonicalRequest.scala x: 5 commits (all time) y: 75 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/FtpBrowserGraphStage.scala x: 4 commits (all time) y: 62 lines of code ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl/SftpOperations.scala x: 6 commits (all time) y: 169 lines of code google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GrpcPublisher.scala x: 4 commits (all time) y: 47 lines of code amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/AmqpConnectionProvider.scala x: 7 commits (all time) y: 315 lines of code google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl/PubSubApi.scala x: 8 commits (all time) y: 233 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/Formats.scala x: 7 commits (all time) y: 224 lines of code unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/scaladsl/UnixDomainSocket.scala x: 6 commits (all time) y: 55 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/model.scala x: 10 commits (all time) y: 712 lines of code mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl/MqttSession.scala x: 4 commits (all time) y: 572 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsProducerStage.scala x: 5 commits (all time) y: 202 lines of code jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/SourceStageLogic.scala x: 4 commits (all time) y: 115 lines of code elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/scaladsl/ElasticsearchFlow.scala x: 4 commits (all time) y: 137 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/DatasetJsonProtocol.scala x: 8 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: 7 commits (all time) y: 200 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/QueryJsonProtocol.scala x: 8 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: 9 commits (all time) y: 141 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/TableJsonProtocol.scala x: 8 commits (all time) y: 203 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryCollectionFormats.scala x: 3 commits (all time) y: 47 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray/BigQueryRestBasicFormats.scala x: 3 commits (all time) y: 33 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleSettings.scala x: 6 commits (all time) y: 205 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl/BigQuery.scala x: 9 commits (all time) y: 188 lines of code google-common/src/main/java/org/apache/pekko/stream/connectors/google/javadsl/XUploadContentType.java x: 3 commits (all time) y: 9 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/javadsl/Google.scala x: 5 commits (all time) y: 32 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmSender.scala x: 5 commits (all time) y: 45 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/model.scala x: 8 commits (all time) y: 167 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/CouchbaseFlow.scala x: 5 commits (all time) y: 154 lines of code cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSession.scala x: 8 commits (all time) y: 83 lines of code couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/DiscoverySupport.scala x: 6 commits (all time) y: 58 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/scaladsl/LogRotatorSink.scala x: 4 commits (all time) y: 165 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryJobs.scala x: 5 commits (all time) y: 114 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryQueries.scala x: 4 commits (all time) y: 110 lines of code google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/BigQueryTables.scala x: 4 commits (all time) y: 60 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/auth/GoogleOAuth2Credentials.scala x: 4 commits (all time) y: 34 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/impl/FcmJsonSupport.scala x: 5 commits (all time) y: 66 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl/FcmJsonSupport.scala x: 4 commits (all time) y: 218 lines of code huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl/PushKitJsonSupport.scala x: 4 commits (all time) y: 193 lines of code ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl/IronMqPullStage.scala x: 4 commits (all time) y: 86 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 csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala x: 3 commits (all time) y: 324 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 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/javadsl/AmqpSource.scala x: 3 commits (all time) y: 16 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 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/CqlSessionProvider.scala x: 3 commits (all time) y: 59 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/impl/CouchbaseSessionImpl.scala x: 3 commits (all time) y: 134 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/CsvQuotingStyle.java x: 2 commits (all time) y: 5 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 dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/DynamoDbOp.scala x: 3 commits (all time) y: 43 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/WriteMessage.scala x: 7 commits (all time) y: 121 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 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/TarReaderStage.scala x: 3 commits (all time) y: 224 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive/ZipReaderSource.scala x: 3 commits (all time) y: 83 lines of code file/src/main/scala/org/apache/pekko/stream/connectors/file/model.scala x: 2 commits (all time) y: 122 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/scaladsl/Geode.scala x: 3 commits (all time) y: 61 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-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/javadsl/GCStorage.scala x: 8 commits (all time) y: 129 lines of code google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmNotificationModels.scala x: 3 commits (all time) y: 147 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/v1/models/AndroidConfig.scala x: 2 commits (all time) y: 108 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/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 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/Sessions.scala x: 3 commits (all time) y: 88 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 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/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/MqttSessionSettings.scala x: 2 commits (all time) y: 127 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 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/PravegaFlow.scala x: 4 commits (all time) y: 94 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 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/headers/ServerSideEncryption.scala x: 3 commits (all time) y: 121 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/model.scala x: 9 commits (all time) y: 936 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 solr/src/main/scala/org/apache/pekko/stream/connectors/solr/SolrMessages.scala x: 6 commits (all time) y: 99 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/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/SqsSource.scala x: 7 commits (all time) y: 48 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
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 602.0
commits (all time)
min: 1.0 | average: 5.31 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 4.0 | max: 602.0

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

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

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

project/Dependencies.scala x: 3 commits (30d) y: 437 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 1 commits (30d) y: 298 lines of code build.sbt x: 1 commits (30d) y: 426 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala x: 1 commits (30d) y: 429 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala x: 1 commits (30d) y: 72 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala x: 1 commits (30d) y: 36 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala x: 1 commits (30d) y: 19 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala x: 1 commits (30d) y: 16 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala x: 1 commits (30d) y: 26 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala x: 1 commits (30d) y: 47 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala x: 1 commits (30d) y: 46 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala x: 1 commits (30d) y: 15 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala x: 1 commits (30d) y: 22 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala x: 1 commits (30d) y: 330 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 1 commits (30d) y: 419 lines of code
437.0
lines of code
  min: 15.0
  average: 166.06
  25th percentile: 19.75
  median: 46.5
  75th percentile: 396.75
  max: 437.0
0 3.0
commits (30d)
min: 1.0 | average: 1.13 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

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

project/Dependencies.scala x: 2 contributors (30d) y: 437 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 1 contributors (30d) y: 298 lines of code build.sbt x: 1 contributors (30d) y: 426 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala x: 1 contributors (30d) y: 429 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala x: 1 contributors (30d) y: 72 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala x: 1 contributors (30d) y: 36 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala x: 1 contributors (30d) y: 19 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala x: 1 contributors (30d) y: 16 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala x: 1 contributors (30d) y: 26 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala x: 1 contributors (30d) y: 47 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala x: 1 contributors (30d) y: 46 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala x: 1 contributors (30d) y: 15 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala x: 1 contributors (30d) y: 22 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala x: 1 contributors (30d) y: 330 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/StorageObject.scala x: 1 contributors (30d) y: 419 lines of code
437.0
lines of code
  min: 15.0
  average: 166.06
  25th percentile: 19.75
  median: 46.5
  75th percentile: 396.75
  max: 437.0
0 2.0
contributors (30d)
min: 1.0 | average: 1.06 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0

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

project/Dependencies.scala x: 3 commits (90d) y: 437 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 1 commits (90d) y: 298 lines of code build.sbt x: 1 commits (90d) y: 426 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala x: 1 commits (90d) y: 429 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala x: 1 commits (90d) y: 72 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala x: 1 commits (90d) y: 36 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala x: 1 commits (90d) y: 19 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala x: 1 commits (90d) y: 16 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala x: 1 commits (90d) y: 26 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala x: 1 commits (90d) y: 47 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala x: 1 commits (90d) y: 46 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala x: 1 commits (90d) y: 15 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala x: 1 commits (90d) y: 22 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala x: 1 commits (90d) y: 330 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 udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl/UdpBind.scala x: 1 commits (90d) y: 78 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttp.scala x: 1 commits (90d) y: 119 lines of code
437.0
lines of code
  min: 15.0
  average: 158.56
  25th percentile: 21.25
  median: 59.5
  75th percentile: 352.25
  max: 437.0
0 3.0
commits (90d)
min: 1.0 | average: 1.11 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0

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

project/Dependencies.scala x: 2 contributors (90d) y: 437 lines of code google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStream.scala x: 1 contributors (90d) y: 298 lines of code build.sbt x: 1 contributors (90d) y: 426 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStage.scala x: 1 contributors (90d) y: 429 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl/MqttFlowStageWithAck.scala x: 1 contributors (90d) y: 72 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttFlow.scala x: 1 contributors (90d) y: 36 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttMessageWithAck.scala x: 1 contributors (90d) y: 19 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSink.scala x: 1 contributors (90d) y: 16 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl/MqttSource.scala x: 1 contributors (90d) y: 26 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/model.scala x: 1 contributors (90d) y: 47 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttFlow.scala x: 1 contributors (90d) y: 46 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSink.scala x: 1 contributors (90d) y: 15 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl/MqttSource.scala x: 1 contributors (90d) y: 22 lines of code mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/settings.scala x: 1 contributors (90d) y: 330 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 udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl/UdpBind.scala x: 1 contributors (90d) y: 78 lines of code google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http/GoogleHttp.scala x: 1 contributors (90d) y: 119 lines of code
437.0
lines of code
  min: 15.0
  average: 158.56
  25th percentile: 21.25
  median: 59.5
  75th percentile: 352.25
  max: 437.0
0 2.0
contributors (90d)
min: 1.0 | average: 1.06 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0