digraph G {
0 [id="node0" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [add#1154326.path AS path#1154399, add#1154326.partitionValues AS partitionValues#1154400, add#1154326.size AS size#1154401L, add#1154326.modificationTime AS modificationTime#1154402L, add#1154326.dataChange AS dataChange#1154403, from_json(StructField(numRecords,LongType,true), StructField(minValues,StructType(StructField(product,StringType,true),StructField(plant,StringType,true),StructField(outboundUnit,DoubleType,true),StructField(stockDatetime,TimestampType,true)),true), StructField(maxValues,StructType(StructField(product,StringType,true),StructField(plant,StringType,true),StructField(outboundUnit,DoubleType,true),StructField(stockDatetime,TimestampType,true)),true), StructField(nullCount,StructType(StructField(product,LongType,true),StructField(plant,LongType,true),StructField(outboundUnit,LongType,true),StructField(stockDatetime,LongType,true),StructField(stockBatchQuantities,LongType,true),StructField(stockBatchShelfLifeEndDatetimes,LongType,true),StructField(dayBucketDemands,LongType,true),StructField(pointInTimeDemands,LongType,true),StructField(openGoodsMovementQuantities,LongType,true),StructField(openGoodsMovementAvailabilityDatetimes,LongType,true),StructField(openGoodsMovementShelfLifeEndDatetimes,LongType,true),StructField(configuration,LongType,true),StructField(timeDependentSettingsName,LongType,true),StructField(timeDependentSettingsStartDatetime,LongType,true),StructField(timeDependentSettingsEndDatetime,LongType,true),StructField(timeDependentSettingsValue,LongType,true)),true), add#1154326.stats, Some(UTC), false) AS stats#1154410, add#1154326.tags AS tags#1154405, add#1154326.deletionVector AS deletionVector#1154406, add#1154326.baseRowId AS baseRowId#1154407L, add#1154326.defaultRowCommitVersion AS defaultRowCommitVersion#1154408L, add#1154326.clusteringProvider AS clusteringProvider#1154409]"];
subgraph cluster1 {
isCluster="true";
id="cluster1";
label="WholeStageCodegen (1)";
tooltip="WholeStageCodegen (1)";
2 [id="node2" labelType="html" label="<br><b>Filter</b><br><br>" tooltip="Filter isnotnull(add#1154326)"];
3 [id="node3" labelType="html" label="<br><b>Scan ExistingRDD Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001353/0_1_10000001353/_delta_log</b><br><br>" tooltip="Scan ExistingRDD Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001353/0_1_10000001353/_delta_log[txn#1154325,add#1154326,remove#1154327,metaData#1154328,protocol#1154329,cdc#1154330,checkpointMetadata#1154331,sidecar#1154332,domainMetadata#1154333,commitInfo#1154334]"];
}
2->0;
3->2;
}
== Physical Plan ==
Project (3)
+- * Filter (2)
+- * Scan ExistingRDD Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001353/0_1_10000001353/_delta_log (1)
(1) Scan ExistingRDD Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001353/0_1_10000001353/_delta_log [codegen id : 1]
Output [10]: [txn#1154325, add#1154326, remove#1154327, metaData#1154328, protocol#1154329, cdc#1154330, checkpointMetadata#1154331, sidecar#1154332, domainMetadata#1154333, commitInfo#1154334]
Arguments: [txn#1154325, add#1154326, remove#1154327, metaData#1154328, protocol#1154329, cdc#1154330, checkpointMetadata#1154331, sidecar#1154332, domainMetadata#1154333, commitInfo#1154334], Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001353/0_1_10000001353/_delta_log MapPartitionsRDD[66309] at start at FileStorageAdapterImpl.java:179, ExistingRDD, UnknownPartitioning(0)
(2) Filter [codegen id : 1]
Input [10]: [txn#1154325, add#1154326, remove#1154327, metaData#1154328, protocol#1154329, cdc#1154330, checkpointMetadata#1154331, sidecar#1154332, domainMetadata#1154333, commitInfo#1154334]
Condition : isnotnull(add#1154326)
(3) Project
Output [11]: [add#1154326.path AS path#1154399, add#1154326.partitionValues AS partitionValues#1154400, add#1154326.size AS size#1154401L, add#1154326.modificationTime AS modificationTime#1154402L, add#1154326.dataChange AS dataChange#1154403, from_json(StructField(numRecords,LongType,true), StructField(minValues,StructType(StructField(product,StringType,true),StructField(plant,StringType,true),StructField(outboundUnit,DoubleType,true),StructField(stockDatetime,TimestampType,true)),true), StructField(maxValues,StructType(StructField(product,StringType,true),StructField(plant,StringType,true),StructField(outboundUnit,DoubleType,true),StructField(stockDatetime,TimestampType,true)),true), StructField(nullCount,StructType(StructField(product,LongType,true),StructField(plant,LongType,true),StructField(outboundUnit,LongType,true),StructField(stockDatetime,LongType,true),StructField(stockBatchQuantities,LongType,true),StructField(stockBatchShelfLifeEndDatetimes,LongType,true),StructField(dayBucketDemands,LongType,true),StructField(pointInTimeDemands,LongType,true),StructField(openGoodsMovementQuantities,LongType,true),StructField(openGoodsMovementAvailabilityDatetimes,LongType,true),StructField(openGoodsMovementShelfLifeEndDatetimes,LongType,true),StructField(configuration,LongType,true),StructField(timeDependentSettingsName,LongType,true),StructField(timeDependentSettingsStartDatetime,LongType,true),StructField(timeDependentSettingsEndDatetime,LongType,true),StructField(timeDependentSettingsValue,LongType,true)),true), add#1154326.stats, Some(UTC), false) AS stats#1154410, add#1154326.tags AS tags#1154405, add#1154326.deletionVector AS deletionVector#1154406, add#1154326.baseRowId AS baseRowId#1154407L, add#1154326.defaultRowCommitVersion AS defaultRowCommitVersion#1154408L, add#1154326.clusteringProvider AS clusteringProvider#1154409]
Input [10]: [txn#1154325, add#1154326, remove#1154327, metaData#1154328, protocol#1154329, cdc#1154330, checkpointMetadata#1154331, sidecar#1154332, domainMetadata#1154333, commitInfo#1154334]