pyspark.sql.functions.assert_true<一個class="headerlink" href="//www.eheci.com/api-docs/python/pyspark/latest/pyspark.sql/api/#pyspark-sql-functions-assert-true" title="¶">¶
-
pyspark.sql.functions。assert_true( 上校:ColumnOrName,errMsg:(pyspark.sql.column聯盟。列,str,沒有)=沒有一個 )→pyspark.sql.column.Column<一個class="headerlink" href="//www.eheci.com/api-docs/python/pyspark/latest/pyspark.sql/api/#pyspark.sql.functions.assert_true" title="¶">¶ -
返回null如果輸入列是正確的;拋出一個異常,否則所提供的錯誤消息。
例子
> > >df=火花。createDataFrame(((0,1)),(“一個”,“b”])> > >df。選擇(assert_true(df。一個<df。b)。別名(“r”))。收集()[行(r = None)]> > >df=火花。createDataFrame(((0,1)),(“一個”,“b”])> > >df。選擇(assert_true(df。一個<df。b,df。一個)。別名(“r”))。收集()[行(r = None)]> > >df=火花。createDataFrame(((0,1)),(“一個”,“b”])> > >df。選擇(assert_true(df。一個<df。b,“錯誤”)。別名(“r”))。收集()[行(r = None)]