diff --git a/wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java b/wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java index d77c51dfe..5fb95c671 100644 --- a/wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java +++ b/wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java @@ -74,16 +74,14 @@ public Tuple, Collection> eval } - //TODO what to write here + ExecutionLineageNode prepareLineageNode = new ExecutionLineageNode(operatorContext); prepareLineageNode.add(LoadProfileEstimators.createFromSpecification( - //TODO what to write here "wayang.java.googlecloudstoragesource.load.prepare", javaExecutor.getConfiguration() )); ExecutionLineageNode mainLineageNode = new ExecutionLineageNode(operatorContext); mainLineageNode.add(LoadProfileEstimators.createFromSpecification( - //TODO what to write here "wayang.java.googlecloudstoragesource.load.main", javaExecutor.getConfiguration() ));