You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/03/31 16:38:22 UTC
[1/2] beam git commit: This closes #2386
Repository: beam
Updated Branches:
refs/heads/master 813839a3b -> d9b053d3a
This closes #2386
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d9b053d3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d9b053d3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d9b053d3
Branch: refs/heads/master
Commit: d9b053d3a5ef38d9d31333d45ac2a3ee153fb01d
Parents: 813839a 054fbad
Author: Thomas Groh <tg...@google.com>
Authored: Fri Mar 31 09:38:11 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Fri Mar 31 09:38:11 2017 -0700
----------------------------------------------------------------------
.../core/construction/PTransformMatchers.java | 45 ++++++++++++++++++++
1 file changed, 45 insertions(+)
----------------------------------------------------------------------
[2/2] beam git commit: Improve PTransformMatcher ToStrings
Posted by tg...@apache.org.
Improve PTransformMatcher ToStrings
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/054fbadd
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/054fbadd
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/054fbadd
Branch: refs/heads/master
Commit: 054fbadd1ad75bde1162e4b1cad4e59e8c1e9e93
Parents: 813839a
Author: Thomas Groh <tg...@google.com>
Authored: Thu Mar 30 17:54:29 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Fri Mar 31 09:38:11 2017 -0700
----------------------------------------------------------------------
.../core/construction/PTransformMatchers.java | 45 ++++++++++++++++++++
1 file changed, 45 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/054fbadd/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java
----------------------------------------------------------------------
diff --git a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java
index d5a91a7..f4ae577 100644
--- a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java
+++ b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java
@@ -17,6 +17,7 @@
*/
package org.apache.beam.runners.core.construction;
+import com.google.common.base.MoreObjects;
import java.util.HashSet;
import java.util.Set;
import org.apache.beam.sdk.annotations.Experimental;
@@ -67,6 +68,13 @@ public class PTransformMatchers {
public boolean matches(AppliedPTransform<?, ?, ?> application) {
return application.getTransform().getClass().equals(clazz);
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper(EqualClassPTransformMatcher.class)
+ .add("class", clazz)
+ .toString();
+ }
}
/**
@@ -85,6 +93,11 @@ public class PTransformMatchers {
}
return false;
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper("SplittableParDoSingleMatcher").toString();
+ }
};
}
@@ -105,6 +118,11 @@ public class PTransformMatchers {
}
return false;
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper("StateOrTimerParDoSingleMatcher").toString();
+ }
};
}
@@ -124,6 +142,11 @@ public class PTransformMatchers {
}
return false;
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper("SplittableParDoMultiMatcher").toString();
+ }
};
}
@@ -144,6 +167,11 @@ public class PTransformMatchers {
}
return false;
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper("StateOrTimerParDoMultiMatcher").toString();
+ }
};
}
@@ -165,6 +193,13 @@ public class PTransformMatchers {
}
return fnType.equals(fn.getClass());
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper("ParDoWithFnTypeMatcher")
+ .add("fnType", fnType)
+ .toString();
+ }
};
}
@@ -179,6 +214,11 @@ public class PTransformMatchers {
return (application.getTransform() instanceof Flatten.PCollections)
&& application.getInputs().isEmpty();
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper("EmptyFlattenMatcher").toString();
+ }
};
}
@@ -201,6 +241,11 @@ public class PTransformMatchers {
}
return false;
}
+
+ @Override
+ public String toString() {
+ return MoreObjects.toStringHelper("FlattenWithDuplicateInputsMatcher").toString();
+ }
};
}