Skip to content

Commit 35be199

Browse files
authored
Merge pull request #537 from jephal/main
cleanup todos
2 parents 4dc3c5f + ef5eef2 commit 35be199

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -74,16 +74,14 @@ public Tuple<Collection<ExecutionLineageNode>, Collection<ChannelInstance>> eval
7474
}
7575

7676

77-
//TODO what to write here
77+
7878
ExecutionLineageNode prepareLineageNode = new ExecutionLineageNode(operatorContext);
7979
prepareLineageNode.add(LoadProfileEstimators.createFromSpecification(
80-
//TODO what to write here
8180

8281
"wayang.java.googlecloudstoragesource.load.prepare", javaExecutor.getConfiguration()
8382
));
8483
ExecutionLineageNode mainLineageNode = new ExecutionLineageNode(operatorContext);
8584
mainLineageNode.add(LoadProfileEstimators.createFromSpecification(
86-
//TODO what to write here
8785

8886
"wayang.java.googlecloudstoragesource.load.main", javaExecutor.getConfiguration()
8987
));

0 commit comments

Comments
 (0)