You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/07/07 04:27:21 UTC
[1/2] beam git commit: Made DataflowRunner TransformTranslator public
Repository: beam
Updated Branches:
refs/heads/master 628dace9c -> 17d7e5980
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/da92256b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/da92256b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/da92256b
Branch: refs/heads/master
Commit: da92256ba64c5f4777776bd6283db2484bd72293
Parents: 1e16aa2
Author: Jeremie Lenfant-Engelmann <je...@google.com>
Authored: Wed Jun 28 16:11:21 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu Jul 6 21:15:05 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/da92256b/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);
/**
[2/2] beam git commit: This closes #3467: Made DataflowRunner
TransformTranslator public
Posted by ke...@apache.org.
This closes #3467: 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/17d7e598
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/17d7e598
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/17d7e598
Branch: refs/heads/master
Commit: 17d7e5980e58a6ee668f41f1518a09bed274b5b2
Parents: 628dace da92256
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Jul 6 21:18:05 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu Jul 6 21:18:05 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/runners/dataflow/TransformTranslator.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------