This is an automated email from the ASF dual-hosted git repository. jbonofre pushed a commit to branch dsl-euphoria in repository https://gitbox.apache.org/repos/asf/beam.git
commit 62f7c1a4a053daaaf8d406dd902ae4b03253e001 Merge: e282336 bc4a6f1 Author: Jean-Baptiste Onofré <jbono...@apache.org> AuthorDate: Wed Jun 6 16:14:08 2018 +0200 Merge pull request #5550 from seznam/dsl-euphoria [BEAM-4410] added Broadcast Join translation .../extensions/euphoria/euphoria-beam/build.gradle | 9 + .../euphoria/beam/BrodcastHashJoinTranslator.java | 196 ++++++++++++++++ .../extensions/euphoria/beam/FlowTranslator.java | 5 +- .../extensions/euphoria/beam/JoinTranslator.java | 31 +-- .../beam/common/OperatorTranslatorUtil.java | 51 ++++ .../sdk/extensions/euphoria/beam/JoinTest.java | 259 ++++++++++++--------- .../euphoria/beam/OperatorsTestSuite.java} | 39 +++- .../beam/testkit}/BroadcastHashJoinTest.java | 6 +- .../euphoria/beam/testkit}/CountByKeyTest.java | 8 +- .../euphoria/beam/testkit}/DistinctTest.java | 8 +- .../euphoria/beam/testkit}/FilterTest.java | 6 +- .../euphoria/beam/testkit}/FlatMapTest.java | 8 +- .../euphoria/beam/testkit}/IntWindow.java | 2 +- .../euphoria/beam/testkit}/JoinTest.java | 8 +- .../beam/testkit}/JoinWindowEnforcementTest.java | 6 +- .../euphoria/beam/testkit}/MapElementsTest.java | 8 +- .../euphoria/beam/testkit}/ReduceByKeyTest.java | 8 +- .../beam/testkit}/ReduceStateByKeyTest.java | 8 +- .../euphoria/beam/testkit}/ReduceWindowTest.java | 6 +- .../euphoria/beam/testkit}/SinkTest.java | 4 +- .../euphoria/beam/testkit}/SumByKeyTest.java | 6 +- .../euphoria/beam/testkit}/TopPerKeyTest.java | 6 +- .../euphoria/beam/testkit}/UnionTest.java | 6 +- .../extensions/euphoria/beam/testkit}/Util.java | 2 +- .../euphoria/beam/testkit}/WatermarkTest.java | 6 +- .../euphoria/beam/testkit}/WindowingTest.java | 6 +- .../beam/testkit}/accumulators/LongCounter.java | 2 +- .../beam/testkit}/accumulators/LongHistogram.java | 2 +- .../testkit}/accumulators/NanosecondTimer.java | 2 +- .../accumulators/SingleJvmAccumulatorProvider.java | 2 +- .../testkit}/accumulators/SnapshotProvider.java | 2 +- .../beam/testkit}/accumulators/Snapshotable.java | 2 +- .../beam/testkit}/accumulators/package-info.java | 2 +- .../beam/testkit}/junit/AbstractOperatorTest.java | 13 +- .../beam/testkit}/junit/ExecutorEnvironment.java | 2 +- .../beam/testkit}/junit/ExecutorProvider.java | 2 +- .../testkit}/junit/ExecutorProviderRunner.java | 4 +- .../euphoria/beam/testkit}/junit/Processing.java | 2 +- .../euphoria/beam/testkit}/junit/package-info.java | 2 +- .../euphoria/beam/testkit}/package-info.java | 2 +- .../extensions/euphoria/euphoria-core/build.gradle | 2 +- .../euphoria/euphoria-local/build.gradle | 2 +- .../local/testkit/LocalExecutorProvider.java | 47 ---- .../executor/local/testkit/LocalOperatorTest.java | 27 --- .../euphoria-operator-testkit/build.gradle | 33 --- .../operator/test/suite/OperatorsTestSuite.java | 53 ----- .../euphoria/operator/test/suite/package-info.java | 22 -- .../euphoria/operator/test/OperatorsTest.java | 27 --- settings.gradle | 2 - 49 files changed, 530 insertions(+), 434 deletions(-) -- To stop receiving notification emails like this one, please contact jbono...@apache.org.