Made DataflowRunner TransformTranslator public
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5e0f2587 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5e0f2587 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5e0f2587 Branch: refs/heads/DSL_SQL Commit: 5e0f2587b95016d0bbf0a1adcebf55ceb7cbc111 Parents: 7b4fa89 Author: Jeremie Lenfant-Engelmann <[email protected]> Authored: Wed Jun 28 16:11:21 2017 -0700 Committer: Tyler Akidau <[email protected]> Committed: Wed Jul 12 20:01:00 2017 -0700 ---------------------------------------------------------------------- .../org/apache/beam/runners/dataflow/TransformTranslator.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/5e0f2587/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TransformTranslator.java ---------------------------------------------------------------------- diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TransformTranslator.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TransformTranslator.java index a7452b2..7f61b6c 100644 --- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TransformTranslator.java +++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TransformTranslator.java @@ -36,7 +36,8 @@ import org.apache.beam.sdk.values.TupleTag; * A {@link TransformTranslator} knows how to translate a particular subclass of {@link PTransform} * for the Cloud Dataflow service. It does so by mutating the {@link TranslationContext}. */ -interface TransformTranslator<TransformT extends PTransform> { +@Internal +public interface TransformTranslator<TransformT extends PTransform> { void translate(TransformT transform, TranslationContext context); /**
