pyspark.streaming.StreamingContext.textFileStream

StreamingContext。 textFileStream ( 目錄:str )→pyspark.streaming.dstream.DStream(str]

創建一個輸入流,監測Hadoop-compatible新文件和文件係統讀取文本文件。文件必須寫入監控目錄由“移動”從另一個位置在同一文件係統。文件名開始。將被忽略。文本文件必須編碼為utf - 8。

以前的

pyspark.streaming.StreamingContext.socketTextStream

下一個

pyspark.streaming.DStream.pprint