== Physical Plan ==
Project (3)
+- Filter (2)
+- Scan ExistingRDD Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000001444/_delta_log (1)
(1) Scan ExistingRDD Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000001444/_delta_log
Output [11]: [path#4772739, partitionValues#4772740, size#4772741L, modificationTime#4772742L, dataChange#4772743, stats#4772750, tags#4772745, deletionVector#4772746, baseRowId#4772747L, defaultRowCommitVersion#4772748L, clusteringProvider#4772749]
Arguments: [path#4772739, partitionValues#4772740, size#4772741L, modificationTime#4772742L, dataChange#4772743, stats#4772750, tags#4772745, deletionVector#4772746, baseRowId#4772747L, defaultRowCommitVersion#4772748L, clusteringProvider#4772749], Delta Table State with Stats #0 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000001444/_delta_log MapPartitionsRDD[332074] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter
Input [11]: [path#4772739, partitionValues#4772740, size#4772741L, modificationTime#4772742L, dataChange#4772743, stats#4772750, tags#4772745, deletionVector#4772746, baseRowId#4772747L, defaultRowCommitVersion#4772748L, clusteringProvider#4772749]
Condition : ((UDF(true, size#4772741L, (stats#4772750.numRecords - coalesce(deletionVector#4772746.cardinality, 0)), stats#4772750.numRecords) AND if (isnull((((isnotnull(partitionValues#4772740[shardId]) AND isnotnull(cast(partitionValues#4772740[sequenceId] as int))) AND (partitionValues#4772740[shardId] = 0_1_10000001444)) AND (cast(partitionValues#4772740[sequenceId] as int) = 8)))) false else UDF(knownnotnull((((isnotnull(partitionValues#4772740[shardId]) AND isnotnull(cast(partitionValues#4772740[sequenceId] as int))) AND (partitionValues#4772740[shardId] = 0_1_10000001444)) AND (cast(partitionValues#4772740[sequenceId] as int) = 8))), size#4772741L, (stats#4772750.numRecords - coalesce(deletionVector#4772746.cardinality, 0)), stats#4772750.numRecords)) AND if (isnull((((stats#4772750.nullCount.worklistShardItemId < stats#4772750.numRecords) AND (stats#4772750.nullCount.orderProposalId < stats#4772750.numRecords)) OR ((isnull(stats#4772750.nullCount.worklistShardItemId) OR isnull(stats#4772750.numRecords)) OR isnull(stats#4772750.nullCount.orderProposalId))))) false else UDF(knownnotnull((((stats#4772750.nullCount.worklistShardItemId < stats#4772750.numRecords) AND (stats#4772750.nullCount.orderProposalId < stats#4772750.numRecords)) OR ((isnull(stats#4772750.nullCount.worklistShardItemId) OR isnull(stats#4772750.numRecords)) OR isnull(stats#4772750.nullCount.orderProposalId)))), size#4772741L, (stats#4772750.numRecords - coalesce(deletionVector#4772746.cardinality, 0)), stats#4772750.numRecords))
(3) Project
Output [11]: [path#4772739, partitionValues#4772740, size#4772741L, modificationTime#4772742L, dataChange#4772743, null AS stats#5467173, tags#4772745, deletionVector#4772746, baseRowId#4772747L, defaultRowCommitVersion#4772748L, clusteringProvider#4772749]
Input [11]: [path#4772739, partitionValues#4772740, size#4772741L, modificationTime#4772742L, dataChange#4772743, stats#4772750, tags#4772745, deletionVector#4772746, baseRowId#4772747L, defaultRowCommitVersion#4772748L, clusteringProvider#4772749]