From ef5eef29b70120cf5bbf2f77b1a88812bb1ee276 Mon Sep 17 00:00:00 2001 From: halv Date: Thu, 10 Apr 2025 09:24:58 +0200 Subject: [PATCH] cleanup todos --- .../wayang/java/operators/JavaGoogleCloudStorageSource.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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() ));