如何檢查dataframe列值嗎

[databicky]

在我dataframe這一列的名字像數,如果特定的列值大於零,這份工作需要失敗,如何執行這一個?

[Chaitanya_Raju]

嗨@Mohammed sadamusean

你可以嚐試在pyspark下麵代碼和讓我知道如果你麵對任何問題

variable_name = df.select(坳(Column_Name)) .collect()[0][0]如果(variable_name > 0): dbutils.notebook。退出(筆記本失敗)

快樂學習! !

[Hubert_Dudek1]

代碼沒有收集,不應該用於生產:

如果df。過濾器(“數> 0”).count () > 0: dbutils.notebook。退出(筆記本失敗)

您還可以使用一個更激進的版本:

如果df。過濾器(“數> 0”).count() > 0:提高異常(“數大於0”)

[databicky]

但它會列的總數,但我需要檢查每一個特定的列值

[Hubert_Dudek1]

首先你行匹配查詢過濾器。你說列命名計數。假設一列叫做坳相反,所以過濾器(“坳> 0”),然後使用count()函數,它將返回多少行符合這些標準。