Repository: beam Updated Branches: refs/heads/master 6bb204f34 -> c687887d2
Make Java serialized CombineFn URN public Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a250ce58 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a250ce58 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a250ce58 Branch: refs/heads/master Commit: a250ce58c6a0caf473842c4e5e6f980a828dde55 Parents: 8fc2eb0 Author: Kenneth Knowles <[email protected]> Authored: Thu May 25 22:51:18 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Fri May 26 10:22:37 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/core/construction/CombineTranslation.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/a250ce58/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java ---------------------------------------------------------------------- diff --git a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java index 855fba7..28bc9a1 100644 --- a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java +++ b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java @@ -49,7 +49,7 @@ import org.apache.beam.sdk.values.PCollection; * RunnerApi.CombinePayload} protos. */ public class CombineTranslation { - private static final String JAVA_SERIALIZED_COMBINE_FN_URN = "urn:beam:java:combinefn:v1"; + public static final String JAVA_SERIALIZED_COMBINE_FN_URN = "urn:beam:java:combinefn:v1"; public static CombinePayload toProto( AppliedPTransform<?, ?, Combine.PerKey<?, ?, ?>> combine, SdkComponents sdkComponents)
