DataStreamReader 類別

定義

命名空間:

Microsoft.Spark.Sql.Streaming

組件:

Microsoft.Spark.dll

套件:

Microsoft.Spark v1.0.0

DataStreamReader 提供從外部儲存系統載入串流 DataFrame 的功能， (例如檔案系統、機碼/值存放區等) 。

public sealed class DataStreamReader

type DataStreamReader = class

Public NotInheritable Class DataStreamReader

繼承

Object

DataStreamReader

方法

Csv(String)	載入 CSV 檔案資料流程，並將結果傳回為 DataFrame 。
Format(String)	指定輸入資料來源格式。
Json(String)	載入 JSON 檔案資料流程，並將結果傳回為 DataFrame 。
Load()	針對不需要路徑 (的資料流程，將輸入資料流程載入為 DataFrame ，例如外部索引鍵/值存放區) 。
Load(String)	針對從某些路徑讀取的資料流程，將輸入 DataFrame 載入為 。
Option(String, Boolean)	新增基礎資料來源的輸入選項。
Option(String, Double)	新增基礎資料來源的輸入選項。
Option(String, Int64)	新增基礎資料來源的輸入選項。
Option(String, String)	新增基礎資料來源的輸入選項。
Options(Dictionary<String,String>)	新增基礎資料來源的輸入選項。
Orc(String)	載入 ORC 檔案資料流程，並將結果傳回為 DataFrame 。
Parquet(String)	載入 Parquet 檔案資料流程，並將結果傳回為 DataFrame 。
Schema(String)	使用指定的 DDL 格式字串來指定架構。
Schema(StructType)	使用 StructType 指定架構。
Text(String)	載入文字檔，並傳回 DataFrame 其架構開頭為 「value」 的字串資料行，如果有的話，後面接著分割的資料行。