== Physical Plan ==
Project (3)
+- Filter (2)
+- Scan ExistingRDD Delta Table State with Stats #499 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-sourceofsupply-sourceofsupply/_delta_log (1)
(1) Scan ExistingRDD Delta Table State with Stats #499 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-sourceofsupply-sourceofsupply/_delta_log
Output [11]: [path#817645, partitionValues#817646, size#817647L, modificationTime#817648L, dataChange#817649, stats#817656, tags#817651, deletionVector#817652, baseRowId#817653L, defaultRowCommitVersion#817654L, clusteringProvider#817655]
Arguments: [path#817645, partitionValues#817646, size#817647L, modificationTime#817648L, dataChange#817649, stats#817656, tags#817651, deletionVector#817652, baseRowId#817653L, defaultRowCommitVersion#817654L, clusteringProvider#817655], Delta Table State with Stats #499 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-sourceofsupply-sourceofsupply/_delta_log MapPartitionsRDD[38351] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)
(2) Filter
Input [11]: [path#817645, partitionValues#817646, size#817647L, modificationTime#817648L, dataChange#817649, stats#817656, tags#817651, deletionVector#817652, baseRowId#817653L, defaultRowCommitVersion#817654L, clusteringProvider#817655]
Condition : ((UDF(true, size#817647L, (stats#817656.numRecords - coalesce(deletionVector#817652.cardinality, 0)), stats#817656.numRecords) AND UDF(true, size#817647L, (stats#817656.numRecords - coalesce(deletionVector#817652.cardinality, 0)), stats#817656.numRecords)) AND if (isnull(((stats#817656.nullCount.internalUUID < stats#817656.numRecords) OR (isnull(stats#817656.nullCount.internalUUID) OR isnull(stats#817656.numRecords))))) false else UDF(knownnotnull(((stats#817656.nullCount.internalUUID < stats#817656.numRecords) OR (isnull(stats#817656.nullCount.internalUUID) OR isnull(stats#817656.numRecords)))), size#817647L, (stats#817656.numRecords - coalesce(deletionVector#817652.cardinality, 0)), stats#817656.numRecords))
(3) Project
Output [11]: [path#817645, partitionValues#817646, size#817647L, modificationTime#817648L, dataChange#817649, null AS stats#905600, tags#817651, deletionVector#817652, baseRowId#817653L, defaultRowCommitVersion#817654L, clusteringProvider#817655]
Input [11]: [path#817645, partitionValues#817646, size#817647L, modificationTime#817648L, dataChange#817649, stats#817656, tags#817651, deletionVector#817652, baseRowId#817653L, defaultRowCommitVersion#817654L, clusteringProvider#817655]