You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2018/06/06 14:14:40 UTC
[beam] 01/01: Merge pull request #5550 from seznam/dsl-euphoria
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é <jb...@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
jbonofre@apache.org.