結構描述

指定輸入結構。 有些資料來源(例如 JSON)能從資料自動推斷輸入結構。 透過在此指定結構,底層資料來源可跳過結構推論步驟,加快資料載入速度。

語法

schema(schema)

參數

參數 類型 說明
schema 結構類型或力量 StructType物件或 DDL 格式的字串(例如 'col0 INT, col1 DOUBLE')。

退貨

DataFrameReader

Examples

讀取 CSV 檔案時請指定結構。

import tempfile
with tempfile.TemporaryDirectory(prefix="schema") as d:
    spark.read.schema("col0 INT, col1 DOUBLE").format("csv").load(d).printSchema()
    # root
    #  |-- col0: integer (nullable = true)
    #  |-- col1: double (nullable = true)