beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [beam] 01/01: Merge pull request #5754: Finalize Samza Runner with gradle and fix findbugs issues
Date Mon, 25 Jun 2018 17:54:27 GMT
This is an automated email from the ASF dual-hosted git repository.

kenn pushed a commit to branch samza-runner
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 038f87d58e2c986f48b4b52c31a294af09e89ba0
Merge: 865a1b9 7c86433
Author: Kenn Knowles <kenn@kennknowles.com>
AuthorDate: Mon Jun 25 10:54:22 2018 -0700

    Merge pull request #5754: Finalize Samza Runner with gradle and fix findbugs issues

 runners/samza/build.gradle                         |  93 +++++++++++++++++++
 runners/samza/pom.xml                              |   5 +-
 .../apache/beam/runners/samza/TestSamzaRunner.java |   4 +-
 .../apache/beam/runners/samza/runtime/DoFnOp.java  |  23 +++--
 .../runtime/DoFnRunnerWithKeyedInternals.java      |   6 +-
 .../beam/runners/samza/runtime/GroupByKeyOp.java   |  33 +++++--
 .../beam/runners/samza/runtime/KeyedInternals.java |   4 +-
 .../beam/runners/samza/runtime/KeyedTimerData.java |   4 +
 .../org/apache/beam/runners/samza/runtime/Op.java  |   2 +-
 .../beam/runners/samza/runtime/OpAdapter.java      |  18 +++-
 .../samza/runtime/SamzaStoreStateInternals.java    |  24 ++---
 .../samza/runtime/SamzaTimerInternalsFactory.java  | 101 +++++----------------
 .../beam/runners/samza/runtime/TimerKey.java       |  92 +++++++++++++++++++
 .../translation/ParDoBoundMultiTranslator.java     |  13 +--
 .../runners/samza/adapter/TestBoundedSource.java   |   6 --
 .../runtime/SamzaStoreStateInternalsTest.java      |   2 +-
 settings.gradle                                    |   2 +
 17 files changed, 293 insertions(+), 139 deletions(-)


Mime
View raw message