apache / incubator-pekko-connectors
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 642 files with 44,164 lines of code in files.
    • 8 files that are 366+ days old (962 lines of code)
    • 1 files that are 181-365 days old (18 lines of code)
    • 631 files that are 91-180 days old (42,920 lines of code)
    • 1 files that are 31-90 days old (223 lines of code)
    • 1 files that are 1-30 days old (41 lines of code)
2% | <1% | 97% | <1% | <1%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 642 files with 44,164 lines of code in files.
    • 2 files have been last changed 366+ days ago (68 lines of code)
    • 0 files have been last changed 181-365 days ago (0 lines of code)
    • 2 files have been last changed 91-180 days ago (214 lines of code)
    • 630 files have been last changed 31-90 days ago (42,494 lines of code)
    • 8 files have been last changed 1-30 days ago (1,388 lines of code)
<1% | 0% | <1% | 96% | 3%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
scala, java, md, xml, yml, sh, txt, pub, json, yaml, sbt, svg, properties, gitignore, gitattributes
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
scala1% | <1% | 98% | <1% | <1%
sbt100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
java0% | 0% | 100% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
scala<1% | 0% | <1% | 97% | 2%
xml100% | 0% | 0% | 0% | 0%
java0% | 0% | 0% | 100% | 0%
sbt0% | 0% | 0% | 0% | 100%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
project74% | 2% | 17% | 0% | 5%
ROOT100% | 0% | 0% | 0% | 0%
scripts100% | 0% | 0% | 0% | 0%
geode2% | 0% | 97% | 0% | 0%
s30% | 0% | 100% | 0% | 0%
mqtt-streaming0% | 0% | 100% | 0% | 0%
jms0% | 0% | 100% | 0% | 0%
google-cloud-bigquery0% | 0% | 100% | 0% | 0%
ftp0% | 0% | 100% | 0% | 0%
google-cloud-storage0% | 0% | 100% | 0% | 0%
amqp0% | 0% | 100% | 0% | 0%
elasticsearch0% | 0% | 100% | 0% | 0%
file0% | 0% | 100% | 0% | 0%
google-common0% | 0% | 100% | 0% | 0%
pravega0% | 0% | 100% | 0% | 0%
sqs0% | 0% | 100% | 0% | 0%
google-fcm0% | 0% | 100% | 0% | 0%
couchbase0% | 0% | 100% | 0% | 0%
google-cloud-bigquery-storage0% | 0% | 100% | 0% | 0%
csv0% | 0% | 100% | 0% | 0%
kinesis0% | 0% | 100% | 0% | 0%
huawei-push-kit0% | 0% | 100% | 0% | 0%
hdfs0% | 0% | 100% | 0% | 0%
mqtt0% | 0% | 100% | 0% | 0%
ironmq0% | 0% | 100% | 0% | 0%
cassandra0% | 0% | 100% | 0% | 0%
xml0% | 0% | 100% | 0% | 0%
google-cloud-pub-sub0% | 0% | 100% | 0% | 0%
solr0% | 0% | 100% | 0% | 0%
unix-domain-socket0% | 0% | 100% | 0% | 0%
google-cloud-pub-sub-grpc0% | 0% | 100% | 0% | 0%
orientdb0% | 0% | 100% | 0% | 0%
influxdb0% | 0% | 67% | 32% | 0%
reference0% | 0% | 100% | 0% | 0%
mongodb0% | 0% | 100% | 0% | 0%
udp0% | 0% | 100% | 0% | 0%
hbase0% | 0% | 100% | 0% | 0%
slick0% | 0% | 100% | 0% | 0%
azure-storage-queue0% | 0% | 100% | 0% | 0%
mqtt-streaming-bench0% | 0% | 100% | 0% | 0%
text0% | 0% | 100% | 0% | 0%
kudu0% | 0% | 100% | 0% | 0%
testkit0% | 0% | 100% | 0% | 0%
avroparquet0% | 0% | 100% | 0% | 0%
dynamodb0% | 0% | 100% | 0% | 0%
sse0% | 0% | 100% | 0% | 0%
simple-codecs0% | 0% | 100% | 0% | 0%
sns0% | 0% | 100% | 0% | 0%
aws-event-bridge0% | 0% | 100% | 0% | 0%
spring-web0% | 0% | 100% | 0% | 0%
json-streaming0% | 0% | 100% | 0% | 0%
csv-bench0% | 0% | 100% | 0% | 0%
awslambda0% | 0% | 100% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
scripts100% | 0% | 0% | 0% | 0%
geode2% | 0% | 0% | 97% | 0%
mqtt-streaming-bench0% | 0% | 100% | 0% | 0%
s30% | 0% | 0% | 99% | <1%
mqtt-streaming0% | 0% | 0% | 87% | 12%
jms0% | 0% | 0% | 100% | 0%
google-cloud-bigquery0% | 0% | 0% | 100% | 0%
ftp0% | 0% | 0% | 100% | 0%
google-cloud-storage0% | 0% | 0% | 100% | 0%
amqp0% | 0% | 0% | 100% | 0%
elasticsearch0% | 0% | 0% | 100% | 0%
file0% | 0% | 0% | 100% | 0%
google-common0% | 0% | 0% | 100% | 0%
pravega0% | 0% | 0% | 100% | 0%
sqs0% | 0% | 0% | 100% | 0%
google-fcm0% | 0% | 0% | 100% | 0%
couchbase0% | 0% | 0% | 100% | 0%
google-cloud-bigquery-storage0% | 0% | 0% | 100% | 0%
csv0% | 0% | 0% | 100% | 0%
kinesis0% | 0% | 0% | 100% | 0%
huawei-push-kit0% | 0% | 0% | 100% | 0%
hdfs0% | 0% | 0% | 100% | 0%
mqtt0% | 0% | 0% | 100% | 0%
ironmq0% | 0% | 0% | 100% | 0%
influxdb0% | 0% | 0% | 100% | 0%
cassandra0% | 0% | 0% | 100% | 0%
xml0% | 0% | 0% | 100% | 0%
google-cloud-pub-sub0% | 0% | 0% | 100% | 0%
solr0% | 0% | 0% | 100% | 0%
unix-domain-socket0% | 0% | 0% | 100% | 0%
google-cloud-pub-sub-grpc0% | 0% | 0% | 100% | 0%
orientdb0% | 0% | 0% | 100% | 0%
reference0% | 0% | 0% | 100% | 0%
mongodb0% | 0% | 0% | 100% | 0%
udp0% | 0% | 0% | 100% | 0%
hbase0% | 0% | 0% | 100% | 0%
slick0% | 0% | 0% | 100% | 0%
azure-storage-queue0% | 0% | 0% | 100% | 0%
text0% | 0% | 0% | 100% | 0%
kudu0% | 0% | 0% | 100% | 0%
testkit0% | 0% | 0% | 100% | 0%
project0% | 0% | 0% | 23% | 76%
avroparquet0% | 0% | 0% | 100% | 0%
dynamodb0% | 0% | 0% | 100% | 0%
sse0% | 0% | 0% | 100% | 0%
simple-codecs0% | 0% | 0% | 100% | 0%
sns0% | 0% | 0% | 100% | 0%
aws-event-bridge0% | 0% | 0% | 100% | 0%
spring-web0% | 0% | 0% | 100% | 0%
json-streaming0% | 0% | 0% | 100% | 0%
csv-bench0% | 0% | 0% | 100% | 0%
awslambda0% | 0% | 0% | 100% | 0%
ROOT0% | 0% | 0% | 0% | 100%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
build.sbt
in root
 383 2 2016-05-10 2023-08-06 286 66 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
plugins.sbt
in project
 24 - 2016-05-10 2023-08-06 136 22 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
Common.scala
in project
 95 1 2016-08-11 2023-06-23 75 18 mmartynas@gmail.com pjfanning@users.noreply.git...
344 1 2016-10-26 2023-08-03 363 102 mmartynas@gmail.com pjfanning@users.noreply.git...
authors.scala
in scripts
 45 - 2017-02-13 2021-05-17 2 2 patrik.nordwall@gmail.com sean@seanglover.com
cache.xml
in geode/scripts
 23 - 2017-02-23 2017-06-04 2 2 olivier.nouguier@gmail.com mmartynas@gmail.com
41 1 2017-09-18 2023-06-23 13 9 github@bzzt.net pjfanning@users.noreply.git...
7 - 2018-03-02 2023-06-23 7 5 458526+ennru@users.noreply.... pjfanning@users.noreply.git...
18 - 2023-01-10 2023-08-06 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
100 3 2023-02-20 2023-08-06 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
17 - 2023-02-20 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1271 52 2023-03-14 2023-06-23 8 3 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 936 61 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ServerState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 808 10 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 708 48 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 655 19 2023-03-14 2023-06-26 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ClientState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 608 8 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MqttSession.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl
 572 13 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsMessages.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 501 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
settings.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 499 19 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
RequestState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 465 11 2023-03-14 2023-08-06 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 429 6 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
StorageObject.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 419 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl
 417 5 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl
 313 20 2023-03-14 2023-06-23 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AmqpConnectionProvider.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 311 15 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
HttpRequests.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 305 15 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MqttFlowStage.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl
 298 17 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 296 16 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpIOGraphStage.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 292 5 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 285 9 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AmqpConnectorSettings.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 263 13 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Marshalling.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 259 - 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PubSubApi.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl
 231 14 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
QueryJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 225 4 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TarReaderStage.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive
 224 1 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 221 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Formats.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 218 8 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl
 218 17 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FcmSettings.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 213 12 2023-03-14 2023-06-23 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
settings.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt
 211 3 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GoogleSettings.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 203 12 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsModel.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 203 21 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 202 11 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JobJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 197 15 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducerStage.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 195 4 2023-03-14 2023-06-26 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PdxEncoder.scala
in geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx
 193 5 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
cache.xml
in geode/scripts
 23 - 2017-02-23 2017-06-04 2 2 olivier.nouguier@gmail.com mmartynas@gmail.com
authors.scala
in scripts
 45 - 2017-02-13 2021-05-17 2 2 patrik.nordwall@gmail.com sean@seanglover.com
MqttPerf.scala
in mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt
 101 3 2023-03-14 2023-03-15 2 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
MqttPerf.scala
in mqtt-streaming-bench/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 113 3 2023-03-14 2023-03-15 2 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
CsvBench.scala
in csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl
 67 4 2023-03-14 2023-05-16 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ApiVersionBase.java
in elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch
 2 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ObjectNotFoundException.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 2 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PravegaEvent.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 3 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
OpensearchParams.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
OpensearchApiVersion.java
in elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsConnectorState.java
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BucketInfo.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MultiPartUpload.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Paginated.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/scaladsl
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TableEntry.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ApiVersion.java
in elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch
 5 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv
 5 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CsvQuotingStyle.java
in csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl
 5 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PekkoPdxSerializer.scala
in geode/src/main/scala/org/apache/pekko/stream/connectors/geode
 5 - 2023-03-14 2023-06-23 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisSchedulerErrors.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis
 5 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducerStatus.java
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CassandraServerMetaData.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryStandardFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryNumber.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Schema.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
DirectoryChange.java
in file/src/main/java/org/apache/pekko/stream/connectors/file
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
OpensearchConnectionSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 7 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
NDJsonProtocol.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 7 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsConsumerControl.java
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/javadsl
 7 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
7 - 2018-03-02 2023-06-23 7 5 458526+ennru@users.noreply.... pjfanning@users.noreply.git...
BigQueryBytes.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 8 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQuerySchemas.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema
 8 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
StandardSchemas.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema
 8 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
attributes.scala
in reference/src/main/scala/org/apache/pekko/stream/connectors/reference
 9 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Strategy.scala
in hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/strategy
 9 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryRestJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 9 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MongoSource.scala
in mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl
 9 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MongoSource.scala
in mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl
 9 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
package.scala
in slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl
 9 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsInternalMatValues.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KuduAttributes.scala
in kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu
 10 - 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ActorName.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 10 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ByteOrderMark.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl
 10 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQuery.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl
 10 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AvroParquetFlow.scala
in avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/javadsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AvroParquetSource.scala
in avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/javadsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AvroParquetFlow.scala
in avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/scaladsl
 10 - 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AvroParquetSource.scala
in avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/scaladsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AwsLambdaFlow.scala
in awslambda/src/main/scala/org/apache/pekko/stream/connectors/awslambda/javadsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
RecordIOFraming.scala
in simple-codecs/src/main/scala/org/apache/pekko/stream/connectors/recordio/scaladsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
41 - 2023-07-28 2023-07-28 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
PekkoConnectorsResultMapperHelper.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 223 10 2023-05-30 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CsvParser.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 324 11 2023-03-16 2023-06-27 3 2 matthew.dedetrich@aiven.io pjfanning@users.noreply.git...
CsvToMapJavaStage.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 122 3 2023-03-16 2023-06-23 2 2 matthew.dedetrich@aiven.io pjfanning@users.noreply.git...
CsvFormatter.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 98 2 2023-03-16 2023-06-23 2 2 matthew.dedetrich@aiven.io pjfanning@users.noreply.git...
CsvToMapStage.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 95 3 2023-03-16 2023-06-23 2 2 matthew.dedetrich@aiven.io pjfanning@users.noreply.git...
CsvParsingStage.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 53 1 2023-03-16 2023-06-23 2 2 matthew.dedetrich@aiven.io pjfanning@users.noreply.git...
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1271 52 2023-03-14 2023-06-23 8 3 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 936 61 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ServerState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 808 10 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 708 48 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 655 19 2023-03-14 2023-06-26 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ClientState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 608 8 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MqttSession.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl
 572 13 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsMessages.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 501 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
settings.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 499 19 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
RequestState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 465 11 2023-03-14 2023-08-06 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 429 6 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
StorageObject.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 419 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl
 417 5 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl
 313 20 2023-03-14 2023-06-23 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AmqpConnectionProvider.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 311 15 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
HttpRequests.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 305 15 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MqttFlowStage.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl
 298 17 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 296 16 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpIOGraphStage.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 292 5 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 285 9 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AmqpConnectorSettings.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 263 13 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Marshalling.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 259 - 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PubSubApi.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl
 231 14 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
QueryJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 225 4 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TarReaderStage.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive
 224 1 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 221 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Formats.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 218 8 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl
 218 17 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FcmSettings.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 213 12 2023-03-14 2023-06-23 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
settings.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt
 211 3 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GoogleSettings.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 203 12 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsModel.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 203 21 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 202 11 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JobJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 197 15 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducerStage.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 195 4 2023-03-14 2023-06-26 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PdxEncoder.scala
in geode/src/main/scala/org/apache/pekko/stream/connectors/geode/impl/pdx
 193 5 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PushKitJsonSupport.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl
 193 10 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpSourceFactory.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 190 10 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
IronMqClient.scala
in ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl
 190 10 2023-03-14 2023-06-26 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQuery.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/javadsl
 182 9 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RequestState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 465 11 2023-03-14 2023-08-06 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
build.sbt
in root
 383 2 2016-05-10 2023-08-06 286 66 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
100 3 2023-02-20 2023-08-06 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
plugins.sbt
in project
 24 - 2016-05-10 2023-08-06 136 22 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
18 - 2023-01-10 2023-08-06 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Utils.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 13 1 2023-03-14 2023-08-06 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
344 1 2016-10-26 2023-08-03 363 102 mmartynas@gmail.com pjfanning@users.noreply.git...
41 - 2023-07-28 2023-07-28 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
CsvParser.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl
 324 11 2023-03-16 2023-06-27 3 2 matthew.dedetrich@aiven.io pjfanning@users.noreply.git...
SourceSettingsBase.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 37 1 2023-03-14 2023-06-27 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 655 19 2023-03-14 2023-06-26 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducerStage.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 195 4 2023-03-14 2023-06-26 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
IronMqClient.scala
in ironmq/src/main/scala/org/apache/pekko/stream/connectors/ironmq/impl
 190 10 2023-03-14 2023-06-26 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FileTailSource.java
in file/src/main/java/org/apache/pekko/stream/connectors/file/impl
 110 5 2023-03-14 2023-06-26 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Slick.scala
in slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl
 39 1 2023-03-14 2023-06-26 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FileTailSource.java
in file/src/main/java/org/apache/pekko/stream/connectors/file/javadsl
 35 3 2023-03-14 2023-06-26 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1271 52 2023-03-14 2023-06-23 8 3 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 936 61 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ServerState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 808 10 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 708 48 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ClientState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 608 8 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MqttSession.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl
 572 13 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsMessages.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 501 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
settings.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 499 19 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 429 6 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
StorageObject.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 419 2 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl
 417 5 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl
 313 20 2023-03-14 2023-06-23 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AmqpConnectionProvider.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 311 15 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
HttpRequests.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 305 15 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MqttFlowStage.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl
 298 17 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 296 16 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpIOGraphStage.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 292 5 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 285 9 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AmqpConnectorSettings.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 263 13 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Marshalling.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 259 - 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PubSubApi.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl
 231 14 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
QueryJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 225 4 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TarReaderStage.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive
 224 1 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PekkoConnectorsResultMapperHelper.scala
in influxdb/src/main/scala/org/apache/pekko/stream/connectors/influxdb/impl
 223 10 2023-05-30 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 221 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Formats.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 218 8 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl
 218 17 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FcmSettings.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 213 12 2023-03-14 2023-06-23 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
settings.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt
 211 3 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GoogleSettings.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 203 12 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsModel.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 203 21 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...