You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by an...@apache.org on 2018/10/09 16:00:12 UTC
[beam] branch master updated (21e30ae -> f6945d5)
This is an automated email from the ASF dual-hosted git repository.
anton pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 21e30ae Merge pull request #6607: [BEAM-4130] Use port 0 to pick dynamic port
add f04a564 [BEAM-5254] Add Samza Runner translator registrar and refactor config generation
add f6945d5 Merge pull request #6292 from xinyuiscool/BEAM-5254
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/runners/samza/SamzaRunner.java | 11 +-
.../runners/samza/adapter/BoundedSourceSystem.java | 25 +---
.../samza/adapter/UnboundedSourceSystem.java | 25 +---
.../runners/samza/translation/ConfigBuilder.java | 148 ++++-----------------
.../runners/samza/translation/ConfigContext.java | 61 +++++++++
.../translation/ParDoBoundMultiTranslator.java | 22 ++-
.../runners/samza/translation/ReadTranslator.java | 47 ++++++-
.../samza/translation/SamzaPipelineTranslator.java | 112 +++++++++++++---
...age-info.java => SamzaTranslatorRegistrar.java} | 8 +-
...anslator.java => TransformConfigGenerator.java} | 7 +-
.../samza/translation/TransformTranslator.java | 2 +-
.../samza/translation/TranslationContext.java | 2 +-
12 files changed, 262 insertions(+), 208 deletions(-)
create mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigContext.java
copy runners/samza/src/main/java/org/apache/beam/runners/samza/translation/{package-info.java => SamzaTranslatorRegistrar.java} (82%)
copy runners/samza/src/main/java/org/apache/beam/runners/samza/translation/{TransformTranslator.java => TransformConfigGenerator.java} (79%)