This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
from 329eaa850 Add sbt-header to code style checks
new f0b637dda try scala 3 (#123)
new f23710ac4 Scala3 couchbase support (#128)
new 7f3a29a6e More scala3 work (cassandra / azure) (#130)
new fc4417af8 support scala3 (google-common) (#141)
new e0202ad93 Scala3 support for more google connectors (#143)
new 4c84bcac2 scala 3 support for json streaming (#146)
new a5796711f Scala3 support for jms connector (#145)
new 1d6a97d05 support ironmq on scala3 (#153)
new 8b7a7a525 scala3 support for hdfs (#156)
new c22f80dc9 support scala3 in mqtt-streaming (#161)
new 54f3c4b68 support scala3 on unix-domain connector (#162)
new 34d15f589 support scala3 for google-cloud-storage connector (#159)
new f5fbaebd5 support scala3 for amqp connector (#154)
new 22332a085 enable scala3 build for more google connectors (#165)
new 02fe31977 Scala3 ftp support (#170)
new 03709901e more connectors that support scala3 (#172)
new 2c00326c3 support scala3 in avroparquet (#158)
new 9f13ddb06 suggested change to queue method call (#174)
new 565651a29 use LEGAL-626 apache header (#182)
new d9f4eed44 acknowledge use of jwt-scala code (#181)
new 26329595a unused import
new 8c5d65051 add scala3 support for s3 (#167)
new 784827a8a Add scala3 support to Azure Storage Queue
The 23 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
LICENSE | 16 +++-
.../connectors/amqp/AmqpConnectionProvider.scala | 54 ++++++++------
.../amqp/impl/AmqpReplyToSinkStage.scala | 4 +-
.../connectors/amqp/impl/AmqpRpcFlowStage.scala | 5 +-
.../connectors/amqp/impl/AmqpSimpleFlowStage.scala | 4 +-
.../connectors/amqp/scaladsl/AmqpSource.scala | 4 +-
.../test/scala/docs/scaladsl/AmqpDocsSpec.scala | 2 +-
.../pekko/stream/connectors/amqp/AmqpSpec.scala | 6 +-
...AmqpGraphStageLogicConnectionShutdownSpec.scala | 9 +--
.../docs/scaladsl/AbstractAvroParquet.scala | 33 +++++++++
.../docs/scaladsl/AbstractAvroParquet.scala | 41 +++++++++++
...Parquet.scala => AbstractAvroParquetBase.scala} | 26 ++-----
.../scala/docs/scaladsl/AvroParquetFlowSpec.scala | 10 +--
.../scala/docs/scaladsl/AvroParquetSinkSpec.scala | 12 +--
.../docs/scaladsl/AvroParquetSourceSpec.scala | 8 +-
.../docs/scaladsl/EventBridgePublisherSpec.scala | 2 +-
.../scala/docs/scaladsl/AwsLambdaFlowSpec.scala | 7 +-
.../storagequeue/impl/AzureQueueSourceStage.scala | 2 +-
.../storagequeue/javadsl/AzureQueueSink.scala | 2 +-
build.sbt | 1 +
.../cassandra/javadsl/CassandraSession.scala | 2 +-
.../cassandra/javadsl/CassandraSessionSpec.scala | 2 +-
.../cassandra/scaladsl/CassandraLifecycle.scala | 5 +-
.../scaladsl/CassandraSessionPerformanceSpec.scala | 2 +-
.../pekko/stream/connectors/couchbase/model.scala | 9 ++-
.../couchbase/scaladsl/CouchbaseFlow.scala | 24 +++---
.../couchbase/scaladsl/DiscoverySupport.scala | 6 +-
.../couchbase/testing/CouchbaseSupport.scala | 15 +++-
.../stream/connectors/csv/scaladsl/CsvBench.scala | 9 +--
csv/src/test/scala/docs/scaladsl/CsvSpec.scala | 2 +-
.../eip/scaladsl/PassThroughExamples.scala | 4 +-
docs/src/main/paradox/avroparquet.md | 4 +-
.../src/test/scala/docs/scaladsl/ExampleSpec.scala | 3 +-
.../elasticsearch/impl/RestBulkApi.scala | 6 +-
.../elasticsearch/scaladsl/ElasticsearchFlow.scala | 2 +-
.../scaladsl/ElasticsearchConnectorBehaviour.scala | 10 +--
.../docs/scaladsl/ElasticsearchSpecUtils.scala | 2 +-
.../scala/docs/scaladsl/ElasticsearchV5Spec.scala | 24 +++---
.../scala/docs/scaladsl/ElasticsearchV7Spec.scala | 24 +++---
.../scaladsl/OpensearchConnectorBehaviour.scala | 10 +--
.../scala/docs/scaladsl/OpensearchV1Spec.scala | 24 +++---
.../connectors/file/javadsl/LogRotatorSink.scala | 33 ++++-----
.../connectors/file/scaladsl/LogRotatorSink.scala | 2 +-
.../scala/docs/scaladsl/LogRotatorSinkSpec.scala | 4 +-
.../connectors/ftp/impl/FtpBrowserGraphStage.scala | 6 +-
.../impl/FtpDirectoryOperationsGraphStage.scala | 2 +-
.../connectors/ftp/impl/FtpGraphStageLogic.scala | 10 +--
.../connectors/ftp/impl/FtpIOGraphStage.scala | 14 ++--
.../pekko/stream/connectors/ftp/impl/FtpLike.scala | 13 ++--
.../stream/connectors/ftp/impl/FtpOperations.scala | 2 +-
.../connectors/ftp/impl/FtpsOperations.scala | 2 +-
.../connectors/ftp/impl/SftpOperations.scala | 2 +-
.../stream/connectors/ftp/javadsl/FtpApi.scala | 4 +-
.../stream/connectors/ftp/scaladsl/FtpApi.scala | 4 +-
.../stream/connectors/ftp/CommonFtpStageSpec.scala | 13 ++--
.../test/scala/docs/scaladsl/GeodeBaseSpec.scala | 2 +-
.../scaladsl/GrpcBigQueryStorageReader.scala | 2 +-
.../test/scala/docs/scaladsl/ExampleReader.scala | 2 +-
.../googlecloud/bigquery/BigQueryException.scala | 4 +-
.../googlecloud/bigquery/javadsl/BigQuery.scala | 29 +++++---
.../bigquery/model/DatasetJsonProtocol.scala | 6 +-
.../bigquery/model/ErrorProtoJsonProtocol.scala | 3 +-
.../bigquery/model/JobJsonProtocol.scala | 21 +++---
.../bigquery/model/QueryJsonProtocol.scala | 9 +--
.../bigquery/model/TableDataJsonProtocol.scala | 18 ++---
.../bigquery/model/TableJsonProtocol.scala | 15 ++--
.../bigquery/scaladsl/BigQueryDatasets.scala | 4 +-
.../bigquery/scaladsl/BigQueryJobs.scala | 8 +-
.../bigquery/scaladsl/BigQueryQueries.scala | 11 +--
.../bigquery/scaladsl/BigQueryTableData.scala | 7 +-
.../bigquery/scaladsl/BigQueryTables.scala | 4 +-
.../scaladsl/spray/BigQueryCollectionFormats.scala | 26 ++++---
.../scaladsl/spray/BigQueryRestBasicFormats.scala | 24 +++---
.../src/test/scala/docs/scaladsl/BigQueryDoc.scala | 12 +--
.../connectors/googlecloud/bigquery/e2e/A.scala | 4 +-
.../e2e/scaladsl/BigQueryEndToEndSpec.scala | 18 +++--
.../bigquery/scaladsl/BigQueryQueriesSpec.scala | 14 ++--
.../scaladsl/schema/BigQuerySchemasSpec.scala | 10 +--
.../scaladsl/spray/BigQueryJsonProtocolSpec.scala | 4 +-
.../pubsub/grpc/javadsl/GooglePubSub.scala | 12 ++-
.../pubsub/grpc/javadsl/GrpcPublisher.scala | 2 +-
.../pubsub/grpc/javadsl/GrpcSubscriber.scala | 2 +-
.../pubsub/grpc/scaladsl/GrpcPublisher.scala | 2 +-
.../pubsub/grpc/scaladsl/GrpcSubscriber.scala | 2 +-
.../src/test/scala/docs/scaladsl/ExampleApp.scala | 2 +-
.../test/scala/docs/scaladsl/IntegrationSpec.scala | 4 +-
.../googlecloud/pubsub/impl/PubSubApi.scala | 48 ++++++------
.../test/scala/docs/scaladsl/ExampleUsage.scala | 2 +-
.../test/scala/docs/scaladsl/IntegrationSpec.scala | 2 +-
.../googlecloud/pubsub/GooglePubSubSpec.scala | 4 +-
.../googlecloud/pubsub/impl/PubSubApiSpec.scala | 4 +-
.../googlecloud/storage/impl/Formats.scala | 29 +++++---
.../googlecloud/storage/impl/GCStorageStream.scala | 17 +++--
.../googlecloud/storage/GCSExtSpec.scala | 2 +-
.../googlecloud/storage/GCStorageExtSpec.scala | 2 +-
.../storage/WithMaterializerGlobal.scala | 6 +-
.../impl/GCStorageStreamIntegrationSpec.scala | 2 +-
.../google/javadsl/XUploadContentType.java | 3 +-
.../stream/connectors/google/GoogleSettings.scala | 8 +-
.../connectors/google/PaginatedRequest.scala | 5 +-
.../stream/connectors/google/ResumableUpload.scala | 60 +++++++--------
.../connectors/google/auth/Credentials.scala | 2 +-
.../google/auth/GoogleComputeMetadata.scala | 5 +-
.../connectors/google/auth/GoogleOAuth2.scala | 8 +-
.../google/auth/GoogleOAuth2Credentials.scala | 2 +-
.../google/auth/GoogleOAuth2Exception.scala | 6 +-
.../connectors/google/auth/NoCredentials.scala | 2 +-
.../google/auth/ServiceAccountCredentials.scala | 2 +-
.../google/auth/UserAccessCredentials.scala | 2 +-
.../google/auth/UserAccessMetadata.scala | 3 +-
.../stream/connectors/google/http/GoogleHttp.scala | 16 ++--
.../stream/connectors/google/javadsl/Google.scala | 4 +-
.../connectors/google/jwt/JwtSprayJson.scala | 84 +++++++++++++++++++++
.../google/scaladsl/`X-Upload-Content-Type`.scala | 2 +-
.../connectors/google/PaginatedRequestSpec.scala | 2 +-
.../connectors/google/ResumableUploadSpec.scala | 6 +-
.../connectors/google/auth/GoogleOAuth2Spec.scala | 10 +--
.../google/auth/OAuth2CredentialsSpec.scala | 5 +-
.../connectors/google/http/GoogleHttpSpec.scala | 9 ++-
.../google/firebase/fcm/impl/FcmFlows.scala | 4 +-
.../google/firebase/fcm/impl/FcmJsonSupport.scala | 10 ++-
.../google/firebase/fcm/impl/FcmSender.scala | 2 +-
.../firebase/fcm/v1/impl/FcmJsonSupport.scala | 4 +-
.../google/firebase/fcm/v1/impl/FcmSender.scala | 2 +-
.../src/test/scala/docs/scaladsl/FcmExamples.scala | 4 +-
.../firebase/fcm/v1/impl/FcmSenderSpec.scala | 6 +-
.../connectors/hbase/impl/HBaseFlowStage.scala | 2 +-
.../connectors/hbase/impl/HBaseSourceStage.scala | 4 +-
.../test/scala/docs/scaladsl/HBaseStageSpec.scala | 2 +-
.../test/scala/docs/scaladsl/HdfsWriterSpec.scala | 2 +-
.../huawei/pushkit/impl/PushKitJsonSupport.scala | 2 +-
.../test/scala/docs/scaladsl/PushKitExamples.scala | 4 +-
.../huawei/pushkit/impl/HmsTokenApiSpec.scala | 2 +-
.../huawei/pushkit/impl/PushKitSenderSpec.scala | 4 +-
.../src/test/scala/docs/scaladsl/FlowSpec.scala | 6 +-
.../scala/docs/scaladsl/InfluxDbSourceSpec.scala | 2 +-
.../test/scala/docs/scaladsl/InfluxDbSpec.scala | 4 +-
.../connectors/ironmq/impl/IronMqPullStage.scala | 4 +-
.../stream/connectors/ironmq/IronMqSpec.scala | 2 +-
.../ironmq/scaladsl/IronMqProducerSpec.scala | 10 +--
.../connectors/jms/impl/GraphStageCompanion.scala | 34 +++++++++
.../connectors/jms/impl/JmsAckSourceStage.scala | 2 +-
.../stream/connectors/jms/impl/JmsConnector.scala | 20 ++---
.../connectors/jms/impl/JmsConsumerStage.scala | 2 +-
.../connectors/jms/impl/JmsProducerStage.scala | 18 ++++-
.../connectors/jms/impl/JmsTxSourceStage.scala | 2 +-
.../connectors/jms/impl/SourceStageLogic.scala | 23 ++++--
.../scaladsl/JmsBufferedAckConnectorsSpec.scala | 2 +-
.../docs/scaladsl/JmsIbmmqConnectorsSpec.scala | 2 +-
.../scala/docs/scaladsl/JmsTxConnectorsSpec.scala | 2 +-
.../pekko/stream/connectors/jms/JmsSpec.scala | 2 +-
.../jms/scaladsl/JmsAckConnectorsSpec.scala | 2 +-
.../connectors/json/impl/JsonStreamReader.scala | 6 +-
.../stream/connectors/kinesis/ShardIterator.scala | 2 +-
.../kinesis/KinesisSchedulerSourceSpec.scala | 36 ++++-----
legal/{S3License.txt => GoogleCommonLicense.txt} | 11 +--
legal/S3License.txt | 7 ++
.../test/scala/docs/scaladsl/MongoSinkSpec.scala | 9 +--
.../test/scala/docs/scaladsl/MongoSourceSpec.scala | 4 +-
.../stream/connectors/mqtt/streaming/model.scala | 18 +++--
.../mqtt/streaming/scaladsl/MqttSession.scala | 4 +-
.../scala/docs/scaladsl/MqttActorSystemsSpec.scala | 6 +-
.../test/scala/docs/scaladsl/MqttFlowSpec.scala | 17 ++---
.../test/scala/docs/scaladsl/OrientDbSpec.scala | 12 +--
.../scala/docs/scaladsl/PravegaReadWriteDocs.scala | 12 +--
.../scala/docs/scaladsl/PravegaSettingsSpec.scala | 4 +-
.../src/test/scala/docs/scaladsl/Serializers.scala | 6 +-
project/Common.scala | 26 +++++--
project/Dependencies.scala | 56 ++++++++------
project/MetaInfLicenseNoticeCopy.scala | 3 +
.../stream/connectors/reference/Resource.scala | 2 +-
.../pekko/stream/connectors/s3/impl/S3Stream.scala | 33 ++++++---
.../connectors/s3/impl/auth/CanonicalRequest.scala | 4 +-
.../pekko/stream/connectors/s3/javadsl/S3.scala | 1 +
.../pekko/stream/connectors/s3/TestUtils.scala | 6 +-
.../connectors/s3/impl/HttpRequestsSpec.scala | 79 ++++++++++++--------
.../stream/connectors/s3/impl/S3StreamSpec.scala | 4 +-
.../connectors/s3/impl/SplitAfterSizeSpec.scala | 3 +-
.../s3/impl/auth/CanonicalRequestSpec.scala | 2 +-
.../connectors/s3/impl/auth/SignerSpec.scala | 2 +-
.../impl/auth/SplitAfterSizeWithContextSpec.scala | 3 +-
.../stream/connectors/s3/impl/retry/Retry.scala | 86 ++++++++++++++++++++++
.../stream/connectors/s3/impl/retry/Timeouts.scala | 45 +++++++++++
.../connectors/s3/scaladsl/S3IntegrationSpec.scala | 6 +-
.../connectors/s3/scaladsl/S3WireMockBase.scala | 3 +-
.../src/test/scala/docs/scaladsl/DocSnippets.scala | 22 +++---
slick/src/test/scala/docs/scaladsl/SlickSpec.scala | 10 +--
.../scala/docs/scaladsl/SnsPublisherSpec.scala | 2 +-
solr/src/test/scala/docs/scaladsl/SolrSpec.scala | 32 ++++----
sqs/src/test/scala/docs/scaladsl/SqsAckSpec.scala | 8 +-
.../test/scala/docs/scaladsl/SqsSourceSpec.scala | 2 +-
.../test/scala/docs/scaladsl/EventSourceSpec.scala | 8 +-
udp/src/test/scala/docs/scaladsl/UdpSpec.scala | 4 +-
.../impl/UnixDomainSocketImpl.scala | 5 +-
.../scaladsl/UnixDomainSocket.scala | 4 +-
195 files changed, 1246 insertions(+), 757 deletions(-)
create mode 100644
avroparquet/src/test/scala-2/docs/scaladsl/AbstractAvroParquet.scala
create mode 100644
avroparquet/src/test/scala-3/docs/scaladsl/AbstractAvroParquet.scala
rename avroparquet/src/test/scala/docs/scaladsl/{AbstractAvroParquet.scala =>
AbstractAvroParquetBase.scala} (88%)
create mode 100644
google-common/src/main/scala/org/apache/pekko/stream/connectors/google/jwt/JwtSprayJson.scala
create mode 100644
jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/GraphStageCompanion.scala
copy legal/{S3License.txt => GoogleCommonLicense.txt} (97%)
create mode 100644
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/retry/Retry.scala
create mode 100644
s3/src/test/scala/org/apache/pekko/stream/connectors/s3/impl/retry/Timeouts.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
