Repository: beam Updated Branches: refs/heads/master 70dd54625 -> b81bd25e1
Make DataflowPipelineTranslator public There are a couple places outside the Beam codebase that still refer to this, and no great reason to break them. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0ca0bdbe Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0ca0bdbe Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0ca0bdbe Branch: refs/heads/master Commit: 0ca0bdbe00381ae6f1b1ddf2c31b4e7b2cbb342f Parents: 70dd546 Author: Kenneth Knowles <k...@google.com> Authored: Mon Jan 9 13:37:55 2017 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Jan 9 14:18:17 2017 -0800 ---------------------------------------------------------------------- .../apache/beam/runners/dataflow/DataflowPipelineTranslator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/0ca0bdbe/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java ---------------------------------------------------------------------- diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java index 524c30b..bd0d5ba 100644 --- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java +++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java @@ -41,6 +41,7 @@ import com.google.api.services.dataflow.model.Environment; import com.google.api.services.dataflow.model.Job; import com.google.api.services.dataflow.model.Step; import com.google.api.services.dataflow.model.WorkerPool; +import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Supplier; import com.google.common.collect.BiMap; import com.google.common.collect.ImmutableBiMap; @@ -106,7 +107,8 @@ import org.slf4j.LoggerFactory; * into Cloud Dataflow Service API {@link Job}s. */ @SuppressWarnings({"rawtypes", "unchecked"}) -class DataflowPipelineTranslator { +@VisibleForTesting +public class DataflowPipelineTranslator { // Must be kept in sync with their internal counterparts. private static final Logger LOG = LoggerFactory.getLogger(DataflowPipelineTranslator.class); private static final ObjectMapper MAPPER = new ObjectMapper();