beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (a60aeba -> 1c9fff2)
Date Tue, 06 Jul 2021 03:07:54 GMT
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.


*** WARNING: tag nightly-master was modified! ***

    from a60aeba  (commit)
      to 1c9fff2  (commit)
    from a60aeba  Merge pull request #14805 from [BEAM-11994] Add HarnessMonitoringInfosRequest/Response
InstructionRequest and MonitoringInfosMetadataRequest/Response support to Java SDK.
     add ada287a  [BEAM-11907] Full function SqsIO Consumer''
     add 52d7400  Add "test" prefix to tests
     add d0463a7  Separate tests to SqsUnboundedReaderTest and SqsUnboundedSourceTest
     add 1c9fff2  Merge pull request #14244: [BEAM-11907] SQS source with full functionality

No new revisions were added by this update.

Summary of changes:
 .../beam/sdk/io/aws/sqs/SqsCheckpointMark.java     |  69 +-
 .../beam/sdk/io/aws/sqs/SqsUnboundedReader.java    | 857 ++++++++++++++++++++-
 .../beam/sdk/io/aws/sqs/SqsUnboundedSource.java    |   7 +-
 .../beam/sdk/io/aws/sqs/EmbeddedSqsServer.java     |  67 ++
 .../org/apache/beam/sdk/io/aws/sqs/SqsIOTest.java  |  67 --
 .../sdk/io/aws/sqs/SqsUnboundedReaderTest.java     | 194 +++++
 .../sdk/io/aws/sqs/SqsUnboundedSourceTest.java}    |  34 +-
 .../beam/sdk/io/aws2/sqs/SqsCheckpointMark.java    |  65 +-
 .../apache/beam/sdk/io/aws2/sqs/SqsMessage.java    |  19 +-
 .../beam/sdk/io/aws2/sqs/SqsUnboundedReader.java   | 836 ++++++++++++++++++--
 .../beam/sdk/io/aws2/sqs/SqsUnboundedSource.java   |   7 +-
 .../beam/sdk/io/aws2/sqs/EmbeddedSqsServer.java    |  13 +-
 .../org/apache/beam/sdk/io/aws2/sqs/SqsIOTest.java |  44 +-
 .../sdk/io/aws2/sqs/SqsUnboundedReaderTest.java    | 204 +++++
 .../sdk/io/aws2/sqs/SqsUnboundedSourceTest.java    |  52 ++
 15 files changed, 2290 insertions(+), 245 deletions(-)
 create mode 100644 sdks/java/io/amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws/sqs/EmbeddedSqsServer.java
 create mode 100644 sdks/java/io/amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws/sqs/SqsUnboundedReaderTest.java
 copy sdks/java/{core/src/test/java/org/apache/beam/sdk/transforms/DoFnTest.java => io/amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws/sqs/SqsUnboundedSourceTest.java}
(51%)
 create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sqs/SqsUnboundedReaderTest.java
 create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sqs/SqsUnboundedSourceTest.java

Mime
View raw message