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 e28233666cb38f6a2809ccfb08a3a3a186903dc8
Merge: eff3ffd 939a104
Author: Jean-Baptiste Onofré <jbono...@apache.org>
AuthorDate: Mon Jun 4 13:50:29 2018 +0200
Merge pull request #5447 from seznam/dsl-euphoria
[BEAM-3900] Join operator translation, Beam windowing, new tests from
operator testsuite enabled .
.../job_beam_PreCommit_Java_GradleBuild.groovy | 2 -
build.gradle | 2 -
.../extensions/euphoria/euphoria-beam/build.gradle | 2 -
.../extensions/euphoria/beam/FlowTranslator.java | 51 ++-
.../extensions/euphoria/beam/JoinTranslator.java | 142 +++++++++
.../euphoria/beam/OperatorTranslator.java | 12 +-
.../euphoria/beam/ReduceByKeyTranslator.java | 39 +--
.../euphoria/beam/ReduceStateByKeyTranslator.java | 2 +-
.../InputToKvDoFn.java} | 36 ++-
.../euphoria/beam/common/package-info.java} | 7 +-
.../extensions/euphoria/beam/join/FullJoinFn.java | 71 +++++
.../extensions/euphoria/beam/join/InnerJoinFn.java | 59 ++++
.../sdk/extensions/euphoria/beam/join/JoinFn.java | 69 ++++
.../euphoria/beam/join/LeftOuterJoinFn.java | 65 ++++
.../euphoria/beam/join/RightOuterJoinFn.java | 62 ++++
.../euphoria/beam/join/package-info.java} | 8 +-
.../euphoria/beam/window/BeamWindowing.java | 77 +++++
.../UnsupportedWindow.java} | 49 ++-
.../euphoria/beam/window/WindowingUtils.java | 75 +++++
.../sdk/extensions/euphoria/beam/JoinTest.java | 216 +++++++++++++
.../extensions/euphoria/beam/ReduceByKeyTest.java | 36 ++-
.../BeamOperatorsTest.java => TestUtils.java} | 15 +-
.../executor/local/testkit/LocalOperatorTest.java | 6 +-
.../euphoria-operator-testkit/build.gradle | 8 +-
.../euphoria/operator/test/AllOperatorsSuite.java | 44 ---
.../euphoria/operator/test/JoinTest.java | 175 +++++++---
.../euphoria/operator/test/ReduceByKeyTest.java | 353 ++++++++++++++++-----
.../operator/test/suite/OperatorsTestSuite.java} | 16 +-
.../operator/test/suite/package-info.java} | 7 +-
.../operator/test}/BeamExecutorProvider.java | 3 +-
.../euphoria/operator/test/OperatorsTest.java} | 8 +-
sdks/java/maven-archetypes/examples/build.gradle | 11 -
sdks/java/maven-archetypes/starter/build.gradle | 11 -
33 files changed, 1436 insertions(+), 303 deletions(-)
--
To stop receiving notification emails like this one, please contact
jbono...@apache.org.
