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(); }