You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/10/13 21:41:24 UTC
[3/3] beam git commit: Align names with those produced by the
dataflow runner harness.
Align names with those produced by the dataflow runner harness.
These will be unused once the runner harness produces the correct
transform payloads.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ec192d15
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ec192d15
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ec192d15
Branch: refs/heads/master
Commit: ec192d15d3e83d6fe2127619c8bbd69e83277918
Parents: a3a7807
Author: Robert Bradshaw <ro...@google.com>
Authored: Wed Oct 4 13:57:01 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Fri Oct 13 14:41:04 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/runners/worker/bundle_processor.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/ec192d15/sdks/python/apache_beam/runners/worker/bundle_processor.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/worker/bundle_processor.py b/sdks/python/apache_beam/runners/worker/bundle_processor.py
index f44490b..05787e1 100644
--- a/sdks/python/apache_beam/runners/worker/bundle_processor.py
+++ b/sdks/python/apache_beam/runners/worker/bundle_processor.py
@@ -58,8 +58,8 @@ IDENTITY_DOFN_URN = 'urn:org.apache.beam:dofn:identity:0.1'
PYTHON_ITERABLE_VIEWFN_URN = 'urn:org.apache.beam:viewfn:iterable:python:0.1'
PYTHON_CODER_URN = 'urn:org.apache.beam:coder:python:0.1'
# TODO(vikasrk): Fix this once runner sends appropriate python urns.
-PYTHON_DOFN_URN = 'urn:org.apache.beam:dofn:java:0.1'
-PYTHON_SOURCE_URN = 'urn:org.apache.beam:source:java:0.1'
+OLD_DATAFLOW_RUNNER_HARNESS_PARDO_URN = 'urn:beam:dofn:javasdk:0.1'
+OLD_DATAFLOW_RUNNER_HARNESS_READ_URN = 'urn:org.apache.beam:source:java:0.1'
def side_input_tag(transform_id, tag):
@@ -358,7 +358,7 @@ def create(factory, transform_id, transform_proto, grpc_port, consumers):
data_channel=factory.data_channel_factory.create_data_channel(grpc_port))
-@BeamTransformFactory.register_urn(PYTHON_SOURCE_URN, None)
+@BeamTransformFactory.register_urn(OLD_DATAFLOW_RUNNER_HARNESS_READ_URN, None)
def create(factory, transform_id, transform_proto, parameter, consumers):
# The Dataflow runner harness strips the base64 encoding.
source = pickler.loads(base64.b64encode(parameter))
@@ -393,7 +393,7 @@ def create(factory, transform_id, transform_proto, parameter, consumers):
consumers)
-@BeamTransformFactory.register_urn(PYTHON_DOFN_URN, None)
+@BeamTransformFactory.register_urn(OLD_DATAFLOW_RUNNER_HARNESS_PARDO_URN, None)
def create(factory, transform_id, transform_proto, parameter, consumers):
dofn_data = pickler.loads(parameter)
if len(dofn_data) == 2: