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
