beam git commit: Fix compile break

2017-08-08 Thread kenn 
Repository: beam
Updated Branches:
  refs/heads/master 89236e3b5 -> 2fa4fdecd


Fix compile break


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2fa4fdec
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2fa4fdec
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2fa4fdec

Branch: refs/heads/master
Commit: 2fa4fdecd8ef06534e369e527b15ae8193823c8b
Parents: 89236e3
Author: Kenneth Knowles 
Authored: Tue Aug 8 09:12:29 2017 -0700
Committer: Kenneth Knowles 
Committed: Tue Aug 8 09:12:29 2017 -0700

--
 .../runners/gearpump/translators/CreateStreamingGearpumpView.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/beam/blob/2fa4fdec/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java
--
diff --git 
a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java
 
b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java
index 60577b3..3ebe5c8 100644
--- 
a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java
+++ 
b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java
@@ -124,8 +124,7 @@ class CreateStreamingGearpumpView
 @Override
 public PCollection> expand(PCollection> input) {
   return PCollection.>createPrimitiveOutputInternal(
-  input.getPipeline(), input.getWindowingStrategy(), 
input.isBounded())
-  .setCoder(input.getCoder());
+  input.getPipeline(), input.getWindowingStrategy(), 
input.isBounded(), input.getCoder());
 }
 
 public PCollectionView getView() {

[2/2] beam git commit: Fix Compile Break in PTransformMatchersTest

2017-04-05 Thread tgroh 
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 
Authored: Wed Apr 5 18:27:46 2017 -0700
Committer: Thomas Groh 
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> viewFn =
 new ViewFn>, Iterable>() {
   @Override
+  public Materialization>> 
getMaterialization() {
+@SuppressWarnings({"rawtypes", "unchecked"})
+Materialization>> materialization =
+(Materialization) Materializations.iterable();
+return materialization;
+  }
+
+  @Override
   public Iterable apply(Iterable> contents) {
 return Collections.emptyList();
   }