[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/DSL_SQL Commit: d302a0f3bcb89d1a2367efb90925ab5abe70f7dd Parents: 78b6e3c Author: Luke Cwik <[email protected]> Authored: Wed Jun 7 07:48:09 2017 -0700 Committer: Luke Cwik <[email protected]> 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; } };
