This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from ea4770bf59c Add controlling multiple models across processes to
CHANGES (#31147)
add f498cdfc2a8 Revert "Add Redistribute transform to Java SDK"
add 3b272d2c6c9 Revert "Add direct Dataflow translation of Redistribute
transform"
add ece456c1a91 Revert "Add Redistribute translation to Spark runner"
add ab9af72aeed Revert "Add Redistribute translation to Samza runner"
add 49056fd7ed1 Revert "Add Redistribute translation to FlinkRunner"
new 8ef90be1b60 Merge pull request #31140: Revert addition of Redistribute
and tests to Java SDK, and translations from runners
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:
runners/flink/flink_runner.gradle | 1 -
runners/flink/job-server/flink_job_server.gradle | 2 -
.../FlinkBatchPortablePipelineTranslator.java | 17 +-
.../flink/FlinkBatchTransformTranslators.java | 78 ----
.../FlinkStreamingPortablePipelineTranslator.java | 22 --
.../flink/FlinkStreamingTransformTranslators.java | 37 --
.../dataflow/DataflowPipelineTranslator.java | 37 --
.../beam/runners/dataflow/util/PropertyNames.java | 1 -
.../translation/RedistributeByKeyTranslator.java | 64 ----
.../samza/translation/ReshuffleTranslator.java | 14 +-
.../samza/translation/SamzaPipelineTranslator.java | 1 -
.../spark/translation/TransformTranslator.java | 66 ----
.../streaming/StreamingTransformTranslator.java | 70 ----
.../apache/beam/sdk/transforms/Redistribute.java | 300 ---------------
.../util/construction/PTransformTranslation.java | 8 -
.../beam/sdk/transforms/RedistributeTest.java | 410 ---------------------
16 files changed, 3 insertions(+), 1125 deletions(-)
delete mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/RedistributeByKeyTranslator.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Redistribute.java
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/RedistributeTest.java
