Filter ((UDF(true, size#772L, (stats#793.numRecords - coalesce(deletionVector#777.cardinality, 0)), stats#793.numRecords) AND UDF(true, size#772L, (stats#793.numRecords - coalesce(deletionVector#777.cardinality, 0)), stats#793.numRecords)) AND if (isnull((((stats#793.nullCount.plant.internalRefUUID < stats#793.numRecords) AND (stats#793.nullCount.product.internalRefUUID < stats#793.numRecords)) OR ((isnull(stats#793.nullCount.plant.internalRefUUID) OR isnull(stats#793.numRecords)) OR isnull(stats#793.nullCount.product.internalRefUUID))))) false else UDF(knownnotnull((((stats#793.nullCount.plant.internalRefUUID < stats#793.numRecords) AND (stats#793.nullCount.product.internalRefUUID < stats#793.numRecords)) OR ((isnull(stats#793.nullCount.plant.internalRefUUID) OR isnull(stats#793.numRecords)) OR isnull(stats#793.nullCount.product.internalRefUUID)))), size#772L, (stats#793.numRecords - coalesce(deletionVector#777.cardinality, 0)), stats#793.numRecords))
Scan ExistingRDD Delta Table State with Stats #65 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/cornerstone/sap-cic-product-productplant/_delta_log[path#770,partitionValues#771,size#772L,modificationTime#773L,dataChange#774,stats#793,tags#776,deletionVector#777,baseRowId#778L,defaultRowCommitVersion#779L,clusteringProvider#780]