You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by xi...@apache.org on 2018/12/18 18:28:43 UTC
[beam] branch master updated (319a370 -> 6ba3a45)
This is an automated email from the ASF dual-hosted git repository.
xinyu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 319a370 Merge pull request #7301: [BEAM-6252] SamzaRunner: Add a registrar to allow customized DoFnInvoker
add 473e5a6 [BEAM-6253] SamzaRunner: Add a few customized transforms for runner use cases
new 6ba3a45 Merge pull request #7302: [BEAM-6253] SamzaRunner: Add a few customized transforms for runner use cases
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/beam/runners/samza/SamzaRunner.java | 2 +-
.../samza/runtime/SamzaStoreStateInternals.java | 10 +++-
.../samza/transforms/GroupWithoutRepartition.java | 60 ++++++++++++++++++++++
.../samza/transforms/UpdatingCombineFn.java | 21 ++++----
.../{metrics => transforms}/package-info.java | 2 +-
.../runners/samza/translation/ConfigContext.java | 9 +++-
.../samza/translation/GroupByKeyTranslator.java | 22 +++++++-
.../samza/translation/SamzaPipelineTranslator.java | 7 ++-
8 files changed, 113 insertions(+), 20 deletions(-)
create mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/transforms/GroupWithoutRepartition.java
copy sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/base/WindowAware.java => runners/samza/src/main/java/org/apache/beam/runners/samza/transforms/UpdatingCombineFn.java (57%)
copy runners/samza/src/main/java/org/apache/beam/runners/samza/{metrics => transforms}/package-info.java (94%)
[beam] 01/01: Merge pull request #7302: [BEAM-6253] SamzaRunner:
Add a few customized transforms for runner use cases
Posted by xi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
xinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 6ba3a4569c93d3a4e1346d4d23ccc242e8a20b7b
Merge: 319a370 473e5a6
Author: xinyuiscool <xi...@gmail.com>
AuthorDate: Tue Dec 18 10:28:36 2018 -0800
Merge pull request #7302: [BEAM-6253] SamzaRunner: Add a few customized transforms for runner use cases
.../org/apache/beam/runners/samza/SamzaRunner.java | 2 +-
.../samza/runtime/SamzaStoreStateInternals.java | 10 +++-
.../samza/transforms/GroupWithoutRepartition.java | 60 ++++++++++++++++++++++
.../samza/transforms/UpdatingCombineFn.java | 35 +++++++++++++
.../runners/samza/transforms/package-info.java | 20 ++++++++
.../runners/samza/translation/ConfigContext.java | 9 +++-
.../samza/translation/GroupByKeyTranslator.java | 22 +++++++-
.../samza/translation/SamzaPipelineTranslator.java | 7 ++-
8 files changed, 158 insertions(+), 7 deletions(-)