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/04/06 02:26:34 UTC
[1/2] beam git commit: This closes #2449
Repository: beam
Updated Branches:
refs/heads/master 20788953f -> 5fd5828d1
This closes #2449
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5fd5828d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5fd5828d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5fd5828d
Branch: refs/heads/master
Commit: 5fd5828d13044028a5b2068c4d1922eb7b27e5a1
Parents: 2078895 f6e9147
Author: Thomas Groh <tg...@google.com>
Authored: Wed Apr 5 19:26:21 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Wed Apr 5 19:26:21 2017 -0700
----------------------------------------------------------------------
.../runners/core/construction/PTransformMatchersTest.java | 10 ++++++++++
1 file changed, 10 insertions(+)
----------------------------------------------------------------------
[2/2] beam git commit: Fix Compile Break in PTransformMatchersTest
Posted by tg...@apache.org.
Fix Compile Break in PTransformMatchersTest
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f6e91470
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f6e91470
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f6e91470
Branch: refs/heads/master
Commit: f6e91470c5e0c805b87dce0101f9e898ccaac116
Parents: 2078895
Author: Thomas Groh <tg...@google.com>
Authored: Wed Apr 5 18:27:46 2017 -0700
Committer: Thomas Groh <tg...@google.com>
Committed: Wed Apr 5 19:26:21 2017 -0700
----------------------------------------------------------------------
.../runners/core/construction/PTransformMatchersTest.java | 10 ++++++++++
1 file changed, 10 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/f6e91470/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/PTransformMatchersTest.java
----------------------------------------------------------------------
diff --git a/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/PTransformMatchersTest.java b/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/PTransformMatchersTest.java
index 1d12194..d053f62 100644
--- a/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/PTransformMatchersTest.java
+++ b/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/PTransformMatchersTest.java
@@ -38,6 +38,8 @@ import org.apache.beam.sdk.transforms.AppliedPTransform;
import org.apache.beam.sdk.transforms.Create;
import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.Flatten;
+import org.apache.beam.sdk.transforms.Materialization;
+import org.apache.beam.sdk.transforms.Materializations;
import org.apache.beam.sdk.transforms.PTransform;
import org.apache.beam.sdk.transforms.ParDo;
import org.apache.beam.sdk.transforms.Sum;
@@ -350,6 +352,14 @@ public class PTransformMatchersTest implements Serializable {
ViewFn<Iterable<WindowedValue<?>>, Iterable<Integer>> viewFn =
new ViewFn<Iterable<WindowedValue<?>>, Iterable<Integer>>() {
@Override
+ public Materialization<Iterable<WindowedValue<?>>> getMaterialization() {
+ @SuppressWarnings({"rawtypes", "unchecked"})
+ Materialization<Iterable<WindowedValue<?>>> materialization =
+ (Materialization) Materializations.iterable();
+ return materialization;
+ }
+
+ @Override
public Iterable<Integer> apply(Iterable<WindowedValue<?>> contents) {
return Collections.emptyList();
}