checks.py does not support where clause filter of deequ

from pydeequ.checks import *
from pydeequ.verification import *

check = Check(spark, CheckLevel.Warning, "Review Check")

checkResult = VerificationSuite(spark) \
.onData(df) \
.addCheck(
check.hasCompleteness('b',lambda x: x >= .5).where("b is not NULL")
deequ support where clause pydeequ have not added the suppport for where clause

Commencez dans checks.py et suivez la manière dont les métriques de Check sont construites à partir de l'appel hasCompleteness de l'exemple. Comparez le chaînage demandé .where("b is not NULL") avec le flux de vérification existant ; le travail est terminé lorsque l'utilisation de la clause where montrée est prise en charge sans casser les checks existants.

Rédigé par le modèle d'indexation à partir du texte de l'issue.