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 2012180 [BEAM-2085] Add capability to declare resource hints in
Python pipeline transforms. (#14390)
add 9ab200c [BEAM-12174] Samza Portable Runner Support (#14554)
No new revisions were added by this update.
Summary of changes:
runners/samza/build.gradle | 2 +-
.../beam/runners/samza/SamzaExecutionContext.java | 117 +--------------
.../apache/beam/runners/samza/SamzaJobInvoker.java | 82 +++++++++++
.../beam/runners/samza/SamzaJobServerDriver.java | 162 +++++++--------------
.../beam/runners/samza/SamzaPipelineRunner.java | 2 +-
.../org/apache/beam/runners/samza/SamzaRunner.java | 5 +-
.../apache/beam/runners/samza/runtime/DoFnOp.java | 9 +-
.../SamzaExecutableStageContextFactory.java} | 26 ++--
.../samza/translation/ImpulseTranslator.java | 6 +-
.../translation/ParDoBoundMultiTranslator.java | 2 +
.../translation/PortableTranslationContext.java | 9 +-
.../samza/util/SamzaPipelineTranslatorUtils.java | 2 +-
12 files changed, 178 insertions(+), 246 deletions(-)
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobInvoker.java
copy
runners/{spark/src/main/java/org/apache/beam/runners/spark/translation/SparkExecutableStageContextFactory.java
=>
samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaExecutableStageContextFactory.java}
(75%)
