pyspark.sql.streaming.DataStreamReader.load¶
-
DataStreamReader。負載( 路徑:可選(str]=沒有一個,格式:可選(str]=沒有一個,模式:(pyspark.sql.types聯盟。StructType str,沒有)=沒有一個,* *選項:OptionalPrimitiveType )→DataFrame¶ -
從數據源加載數據流並返回它
DataFrame。- 參數
-
- 路徑 str,可選
-
可選的字符串文件係統支持的數據源。
- 格式 str,可選
-
可選的字符串格式數據源。默認為“鋪”。
-
模式
pyspark.sql.types.StructType或str,可選 -
可選
pyspark.sql.types.StructType輸入模式或DDL-formatted字符串(例如col0INT,col1雙)。 - * *選項 dict
-
所有其他選項字符串
筆記
這個API是不斷發展的。
例子
> > >json_sdf=火花。readStream。格式(“json”)\…。模式(sdf_schema)\…。負載(tempfile。mkdtemp())> > >json_sdf。isStreaming真正的> > >json_sdf。模式= =sdf_schema真正的