From commits-return-114344-archive-asf-public=cust-asf.ponee.io@beam.apache.org Mon Jul 5 15:21:31 2021 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-ec2-va.apache.org (mxout1-ec2-va.apache.org [3.227.148.255]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id 50535180648 for ; Mon, 5 Jul 2021 17:21:31 +0200 (CEST) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-ec2-va.apache.org (ASF Mail Server at mxout1-ec2-va.apache.org) with SMTP id 828A73F030 for ; Mon, 5 Jul 2021 15:21:30 +0000 (UTC) Received: (qmail 47690 invoked by uid 500); 5 Jul 2021 15:21:30 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 47681 invoked by uid 99); 5 Jul 2021 15:21:30 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 05 Jul 2021 15:21:30 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id EF9768DC92; Mon, 5 Jul 2021 15:21:29 +0000 (UTC) Date: Mon, 05 Jul 2021 15:21:18 +0000 To: "commits@beam.apache.org" Subject: [beam] branch master updated (a60aeba -> 1c9fff2) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <162549847437.24955.2707244194458260765@gitbox.apache.org> From: aromanenko@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: beam X-Git-Refname: refs/heads/master X-Git-Reftype: branch X-Git-Oldrev: a60aebaac9c90d393ca1e2a7445d45222d908541 X-Git-Newrev: 1c9fff2a5f93b42798b006098bd60aab0877013e X-Git-NotificationType: ref_changed X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. aromanenko pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. 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