pyspark.sql.streaming.DataStreamReader.parquet¶
-
DataStreamReader。拚花( 路徑:str,mergeSchema:可選(bool]=沒有一個,pathGlobFilter:聯盟(bool, str,沒有)=沒有一個,recursiveFileLookup:聯盟(bool, str,沒有)=沒有一個,datetimeRebaseMode:聯盟(bool, str,沒有)=沒有一個,int96RebaseMode:聯盟(bool, str,沒有)=沒有一個 )→DataFrame¶ -
加載一個鑲花的文件流,作為一個返回結果
DataFrame。- 參數
-
- 路徑 str
-
路徑在任何Hadoop文件係統的支持
- 其他參數
-
- 額外的選項
-
額外的選項,請參考數據源的選擇。在你使用的版本。
例子
> > >parquet_sdf=火花。readStream。模式(sdf_schema)。拚花(tempfile。mkdtemp())> > >parquet_sdf。isStreaming真正的> > >parquet_sdf。模式= =sdf_schema真正的