pyspark.sql.DataFrame.isStreaming

財產 DataFrame。 isStreaming

返回真正的如果這DataFrame包含一個或多個源不斷地返回數據,因為它的到來。一個DataFrame從流中讀取數據來源必須作為一個執行StreamingQuery使用start ()方法DataStreamWriter。方法返回一個單一的答案,(例如,count ()或收集())將拋出一個AnalysisException當有一個流源。

筆記

這個API是不斷發展的。

以前的

pyspark.sql.DataFrame.isLocal

下一個

pyspark.sql.DataFrame.join