[BEAM-1069] Update parent version and update PTransform expand()

apache · Dec 14, 2016 · ec52a24 · ec52a24
1 parent 2e2ae69
commit ec52a24
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/sdks/java/io/exec/pom.xml b/sdks/java/io/exec/pom.xml
@@ -22,7 +22,7 @@
   <parent>
     <groupId>org.apache.beam</groupId>
     <artifactId>beam-sdks-java-io-parent</artifactId>
-    <version>0.4.0-incubating-SNAPSHOT</version>
+    <version>0.5.0-incubating-SNAPSHOT</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

diff --git a/sdks/java/io/exec/src/main/java/org/apache/beam/sdk/io/exec/ExecIO.java b/sdks/java/io/exec/src/main/java/org/apache/beam/sdk/io/exec/ExecIO.java
@@ -170,7 +170,7 @@ public Read withTimeout(long timeout) {
     }
 
     @Override
-    public PCollection<String> apply(PBegin input) {
+    public PCollection<String> expand(PBegin input) {
       return input
           .apply(Create.of(getCommand()))
           .apply(ParDo.of(new ExecFn(getExecOptions())));
@@ -225,7 +225,7 @@ public Write withTimeout(long timeout) {
     }
 
     @Override
-    public PDone apply(PCollection<String> input) {
+    public PDone expand(PCollection<String> input) {
       input.apply(ParDo.of(new ExecFn(getExecOptions())));
       return PDone.in(input.getPipeline());
     }