From commits-return-99504-archive-asf-public=cust-asf.ponee.io@beam.apache.org Fri Nov 9 18:29:58 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id B808E18067A for ; Fri, 9 Nov 2018 18:29:57 +0100 (CET) Received: (qmail 24536 invoked by uid 500); 9 Nov 2018 17:29:56 -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 24525 invoked by uid 99); 9 Nov 2018 17:29:56 -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; Fri, 09 Nov 2018 17:29:56 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 1A4A7870A5; Fri, 9 Nov 2018 17:29:56 +0000 (UTC) Date: Fri, 09 Nov 2018 17:29:54 +0000 To: "commits@beam.apache.org" Subject: [beam] 01/01: Merge pull request #6750: [BEAM-5790] Euphoria: Remove Dataset abstraction. MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit From: dmvk@apache.org In-Reply-To: <154178459283.2972.13469491811259841567@gitbox.apache.org> References: <154178459283.2972.13469491811259841567@gitbox.apache.org> X-Git-Host: gitbox.apache.org X-Git-Repo: beam X-Git-Refname: refs/heads/master X-Git-Reftype: branch X-Git-Rev: f911be4337b5fd66cd78e1871f186c095b015ddd X-Git-NotificationType: diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated Message-Id: <20181109172956.1A4A7870A5@gitbox.apache.org> This is an automated email from the ASF dual-hosted git repository. dmvk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit f911be4337b5fd66cd78e1871f186c095b015ddd Merge: 8a88e72 07faaa9 Author: David Moravek AuthorDate: Fri Nov 9 18:29:46 2018 +0100 Merge pull request #6750: [BEAM-5790] Euphoria: Remove Dataset abstraction. .../euphoria/core/client/dataset/Dataset.java | 109 ------- .../euphoria/core/client/dataset/package-info.java | 22 -- .../euphoria/core/client/lib/Euphoria.java | 51 --- .../extensions/euphoria/core/client/lib/Split.java | 32 +- .../core/client/operator/AssignEventTime.java | 40 ++- .../core/client/operator/CompositeOperator.java | 6 +- .../euphoria/core/client/operator/CountByKey.java | 45 ++- .../euphoria/core/client/operator/Distinct.java | 42 ++- .../euphoria/core/client/operator/Filter.java | 30 +- .../euphoria/core/client/operator/FlatMap.java | 40 +-- .../euphoria/core/client/operator/FullJoin.java | 18 +- .../euphoria/core/client/operator/Join.java | 64 ++-- .../euphoria/core/client/operator/LeftJoin.java | 18 +- .../euphoria/core/client/operator/MapElements.java | 43 ++- .../core/client/operator/OutputValues.java | 59 ++++ .../euphoria/core/client/operator/ReduceByKey.java | 54 ++-- .../core/client/operator/ReduceWindow.java | 40 ++- .../euphoria/core/client/operator/RightJoin.java | 18 +- .../euphoria/core/client/operator/SumByKey.java | 45 ++- .../euphoria/core/client/operator/TopPerKey.java | 29 +- .../euphoria/core/client/operator/Union.java | 52 ++- .../core/client/operator/base/Builders.java | 10 +- .../core/client/operator/base/ShuffleOperator.java | 2 +- .../euphoria/core/client/type/TypeUtils.java | 23 -- .../util/PCollectionLists.java} | 15 +- .../translate/CompositeOperatorTranslator.java | 48 +++ .../euphoria/core/translate/FlatMapTranslator.java | 3 +- .../euphoria/core/translate/OperatorTransform.java | 32 +- .../core/translate/ReduceByKeyTranslator.java | 5 +- .../core/translate/SimpleTranslatorProvider.java | 12 +- .../euphoria/core/client/lib/SplitTest.java | 26 +- .../core/client/operator/CountByKeyTest.java | 37 +-- .../core/client/operator/DistinctTest.java | 30 +- .../euphoria/core/client/operator/FilterTest.java | 16 +- .../euphoria/core/client/operator/FlatMapTest.java | 30 +- .../euphoria/core/client/operator/JoinTest.java | 186 +++++------ .../core/client/operator/MapElementsTest.java | 30 +- .../core/client/operator/ReduceByKeyTest.java | 76 ++--- .../core/client/operator/ReduceWindowTest.java | 30 +- .../core/client/operator/SumByKeyTest.java | 30 +- .../{OperatorTestUtils.java => TestUtils.java} | 72 ++++- .../core/client/operator/TopPerKeyTest.java | 30 +- .../euphoria/core/client/operator/UnionTest.java | 53 ++-- .../euphoria/core/client/util/IOUtilsTest.java | 6 +- .../core/docs/DocumentationExamplesTest.java | 350 +++++++++------------ .../core/testkit/AbstractOperatorTest.java | 19 +- .../core/testkit/BroadcastHashJoinTest.java | 16 +- .../euphoria/core/testkit/CountByKeyTest.java | 6 +- .../euphoria/core/testkit/DistinctTest.java | 8 +- .../euphoria/core/testkit/FilterTest.java | 4 +- .../euphoria/core/testkit/FlatMapTest.java | 6 +- .../extensions/euphoria/core/testkit/JoinTest.java | 76 ++--- .../euphoria/core/testkit/MapElementsTest.java | 6 +- .../euphoria/core/testkit/ReduceByKeyTest.java | 149 +-------- .../euphoria/core/testkit/ReduceWindowTest.java | 18 +- .../euphoria/core/testkit/SumByKeyTest.java | 7 +- .../euphoria/core/testkit/TopPerKeyTest.java | 12 +- .../euphoria/core/testkit/UnionTest.java | 37 ++- .../core/translate/BeamMetricsTranslationTest.java | 11 +- .../euphoria/core/translate/EuphoriaTest.java | 103 ------ website/src/documentation/sdks/euphoria.md | 154 ++++----- 61 files changed, 1097 insertions(+), 1544 deletions(-)