You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by th...@apache.org on 2016/11/07 19:59:15 UTC
[25/50] incubator-beam git commit: DoFnSignature: Make
TypeDescriptor-returning methods public
DoFnSignature: Make TypeDescriptor-returning methods public
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/71fa7cdf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/71fa7cdf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/71fa7cdf
Branch: refs/heads/apex-runner
Commit: 71fa7cdf17e9719ae7fd606a5406ebe5821eb41e
Parents: 8336b24
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Nov 1 14:50:24 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu Nov 3 21:32:53 2016 -0700
----------------------------------------------------------------------
.../beam/sdk/transforms/reflect/DoFnSignature.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/71fa7cdf/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java
index 6b98805..431de02 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java
@@ -341,7 +341,7 @@ public abstract class DoFnSignature {
/** Concrete type of the {@link RestrictionTracker} parameter, if present. */
@Nullable
- abstract TypeDescriptor<?> trackerT();
+ public abstract TypeDescriptor<?> trackerT();
/** Whether this {@link DoFn} returns a {@link ProcessContinuation} or void. */
public abstract boolean hasReturnValue();
@@ -461,7 +461,7 @@ public abstract class DoFnSignature {
public abstract Method targetMethod();
/** Type of the returned restriction. */
- abstract TypeDescriptor<?> restrictionT();
+ public abstract TypeDescriptor<?> restrictionT();
static GetInitialRestrictionMethod create(Method targetMethod, TypeDescriptor<?> restrictionT) {
return new AutoValue_DoFnSignature_GetInitialRestrictionMethod(targetMethod, restrictionT);
@@ -476,7 +476,7 @@ public abstract class DoFnSignature {
public abstract Method targetMethod();
/** Type of the restriction taken and returned. */
- abstract TypeDescriptor<?> restrictionT();
+ public abstract TypeDescriptor<?> restrictionT();
static SplitRestrictionMethod create(Method targetMethod, TypeDescriptor<?> restrictionT) {
return new AutoValue_DoFnSignature_SplitRestrictionMethod(targetMethod, restrictionT);
@@ -491,10 +491,10 @@ public abstract class DoFnSignature {
public abstract Method targetMethod();
/** Type of the input restriction. */
- abstract TypeDescriptor<?> restrictionT();
+ public abstract TypeDescriptor<?> restrictionT();
/** Type of the returned {@link RestrictionTracker}. */
- abstract TypeDescriptor<?> trackerT();
+ public abstract TypeDescriptor<?> trackerT();
static NewTrackerMethod create(
Method targetMethod, TypeDescriptor<?> restrictionT, TypeDescriptor<?> trackerT) {
@@ -510,7 +510,7 @@ public abstract class DoFnSignature {
public abstract Method targetMethod();
/** Type of the returned {@link Coder}. */
- abstract TypeDescriptor<?> coderT();
+ public abstract TypeDescriptor<?> coderT();
static GetRestrictionCoderMethod create(Method targetMethod, TypeDescriptor<?> coderT) {
return new AutoValue_DoFnSignature_GetRestrictionCoderMethod(targetMethod, coderT);