Remove last use of PCollectionView.fromIterableInternal

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

Branch: refs/heads/master
Commit: 1ab5d00e78a124d297c45edc8c6b55d7c2683543
Parents: 135790b
Author: Kenneth Knowles <k...@google.com>
Authored: Mon Oct 10 13:22:02 2016 -0700
Committer: Kenneth Knowles <k...@google.com>
Committed: Tue Oct 11 20:42:36 2016 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/beam/runners/core/SideInputHandler.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/1ab5d00e/runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java
----------------------------------------------------------------------
diff --git 
a/runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java
 
b/runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java
index 851ed37..ae7f759 100644
--- 
a/runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java
+++ 
b/runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java
@@ -187,7 +187,7 @@ public class SideInputHandler implements 
ReadyCheckingSideInputReader {
 
     Iterable<WindowedValue<?>> elements = state.read();
 
-    return sideInput.fromIterableInternal(elements);
+    return sideInput.getViewFn().apply(elements);
   }
 
   @Override

Reply via email to