You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/06/07 16:01:43 UTC
[1/2] beam git commit: [BEAM-1231] Add missed "kind:bytes" to
CloudObjectKinds/CloudObjectTranslators
Repository: beam
Updated Branches:
refs/heads/master 78b6e3cdd -> b2de3db89
[BEAM-1231] Add missed "kind:bytes" to CloudObjectKinds/CloudObjectTranslators
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d302a0f3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d302a0f3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d302a0f3
Branch: refs/heads/master
Commit: d302a0f3bcb89d1a2367efb90925ab5abe70f7dd
Parents: 78b6e3c
Author: Luke Cwik <lc...@google.com>
Authored: Wed Jun 7 07:48:09 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Jun 7 07:53:42 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/runners/dataflow/util/CloudObjectKinds.java | 1 +
.../beam/runners/dataflow/util/CloudObjectTranslators.java | 5 +++--
2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/d302a0f3/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectKinds.java
----------------------------------------------------------------------
diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectKinds.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectKinds.java
index 403ade2..58bc446 100644
--- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectKinds.java
+++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectKinds.java
@@ -28,4 +28,5 @@ class CloudObjectKinds {
static final String KIND_PAIR = "kind:pair";
static final String KIND_STREAM = "kind:stream";
static final String KIND_WINDOWED_VALUE = "kind:windowed_value";
+ static final String KIND_BYTES = "kind:bytes";
}
http://git-wip-us.apache.org/repos/asf/beam/blob/d302a0f3/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java
----------------------------------------------------------------------
diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java
index 012a669..ad2363d 100644
--- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java
+++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java
@@ -279,7 +279,8 @@ class CloudObjectTranslators {
@Override
public CloudObject toCloudObject(ByteArrayCoder target) {
return addComponents(
- CloudObject.forClass(target.getClass()), Collections.<Coder<?>>emptyList());
+ CloudObject.forClassName(CloudObjectKinds.KIND_BYTES),
+ Collections.<Coder<?>>emptyList());
}
@Override
@@ -294,7 +295,7 @@ class CloudObjectTranslators {
@Override
public String cloudObjectClassName() {
- return CloudObject.forClass(ByteArrayCoder.class).getClassName();
+ return CloudObjectKinds.KIND_BYTES;
}
};
[2/2] beam git commit: [BEAM-1231] Add missed "kind:bytes" to
CloudObjectKinds/CloudObjectTranslators
Posted by lc...@apache.org.
[BEAM-1231] Add missed "kind:bytes" to CloudObjectKinds/CloudObjectTranslators
This closes #3310
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b2de3db8
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b2de3db8
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b2de3db8
Branch: refs/heads/master
Commit: b2de3db899a6e1bfc48dc31d76761b3cf6089c2a
Parents: 78b6e3c d302a0f
Author: Luke Cwik <lc...@google.com>
Authored: Wed Jun 7 09:01:35 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Jun 7 09:01:35 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/runners/dataflow/util/CloudObjectKinds.java | 1 +
.../beam/runners/dataflow/util/CloudObjectTranslators.java | 5 +++--
2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------