This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from a27faca Update Dataflow Python container to beam-master-20201005
(#13011)
add ed6f9ca [BEAM-10670] Support impulse within non-portable Spark
implementations.
add bc4de2e Merge pull request #13018: [BEAM-10670] Support impulse
within non-portable Spark implementations.
No new revisions were added by this update.
Summary of changes:
runners/spark/build.gradle | 7 ++--
...latorBatch.java => ImpulseTranslatorBatch.java} | 46 +++++++++-------------
.../translation/batch/PipelineTranslatorBatch.java | 2 +
.../spark/translation/TransformTranslator.java | 23 +++++++++++
.../streaming/StreamingTransformTranslator.java | 30 ++++++++++++++
5 files changed, 76 insertions(+), 32 deletions(-)
copy
runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/{CreatePCollectionViewTranslatorBatch.java
=> ImpulseTranslatorBatch.java} (51%)
