@Retko Okter:
在火花中使用isEmpty DataFrame API的方法檢查如果δ表是空的
從三角洲。表導入DeltaTable def is_delta_table_empty (table_name): delta_table = DeltaTable。forPath(火花,table_name)返回delta_table.toDF () .isEmpty() #用法的例子如果is_delta_table_empty (“table_name”):打印(“表是空的”)其他:打印(表非空)
@Retko Okter:
在火花中使用isEmpty DataFrame API的方法檢查如果δ表是空的
從三角洲。表導入DeltaTable def is_delta_table_empty (table_name): delta_table = DeltaTable。forPath(火花,table_name)返回delta_table.toDF () .isEmpty() #用法的例子如果is_delta_table_empty (“table_name”):打印(“表是空的”)其他:打印(表非空)