This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from b292235 Merge pull request #6365: [BEAM-5342] Upgrades Google API
Client libraries to 1.24.1
add d82a8a5 specify localhost for portable flink VR tests
add e331952 enumerate primitive transforms in portable construction
add d987918 Update deprecation comment.
add 5dc6ed2 Swap from READ_TRANSFORM to PAR_DO_TRANSFORM
add 2b94f2e Update comment.
add 52e21d4 Fix tests expectations and minor code fix up.
add af58bd2 Merge pull request #1 from lukecwik/pr6328
add 59570db checkstyle nit
add ef202f1 Merge remote-tracking branch 'upstream/HEAD' into vro
add 727ae56 use artificial subtransforms of primitives
add d3772a8 import URNs more directly in QueryablePipeline
add 80a1102 add splittable URNs as primitives
add f0a0e93 [BEAM-4176] Add the ability to allow for runners to register
native transforms.
add 408473d Merge pull request #2 from lukecwik/pr6328
add c75b5f4 add NativeTransform test assertions
new c49a97e [BEAM-4176] enumerate primitive transforms in portable
construction
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:
.../core/construction/NativeTransforms.java | 63 +++++++++++++
.../core/construction/PTransformTranslation.java | 13 +++
.../core/construction/graph/QueryablePipeline.java | 46 ++++++++--
...eFactoryTest.java => NativeTransformsTest.java} | 42 +++++----
.../graph/GreedyPipelineFuserTest.java | 10 +-
.../construction/graph/GreedyStageFuserTest.java | 10 ++
.../construction/graph/OutputDeduplicatorTest.java | 102 ++++++++++++++++++++-
.../construction/graph/QueryablePipelineTest.java | 21 ++++-
runners/flink/job-server/build.gradle | 2 +-
.../java/org/apache/beam/sdk/PipelineTest.java | 2 +-
10 files changed, 273 insertions(+), 38 deletions(-)
create mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/NativeTransforms.java
copy
runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/{UnsupportedOverrideFactoryTest.java
=> NativeTransformsTest.java} (50%)
