Skip to content

Commit 83477be

Browse files
committed
fix: PersistentDataset delegate to SparkDataset
1 parent 15aadc3 commit 83477be

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

vtl-spark/src/main/java/fr/insee/vtl/spark/SparkProcessingEngine.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -164,6 +164,9 @@ private SparkDataset asSparkDataset(DatasetExpression expression) {
164164
return datasetExpression.resolve(Map.of());
165165
} else {
166166
var dataset = expression.resolve(Map.of());
167+
if (dataset instanceof PersistentDataset persistentDataset) {
168+
dataset = persistentDataset.getDelegate();
169+
}
167170
if (dataset instanceof SparkDataset sparkDataset) {
168171
return sparkDataset;
169172
} else {

0 commit comments

Comments
 (0)