スキーマ（データソース）

データソースのスキーマを返します。

ユーザーが明示的に指定しない場合、 __init__メソッドで初期化された任意のフィールドを参照してデータソースのスキーマを推測することができます。このメソッドは、データソース読み取り操作のスキーマを取得するためにspark.read.format(...).load()を呼び出す際に一度だけ呼び出されます。このメソッドが実装されておらず、ユーザーがデータソースを読み込む際にスキーマを提供しない場合、例外がスローされます。

構文

schema()

戻り値

StructType または str

このデータ ソースのスキーマ、またはスキーマを表す DDL 文字列。

例

DDL 文字列を返します。

Python

def schema(self):
    return "a INT, b STRING"

StructTypeを返します。

Python

def schema(self):
    return StructType().add("a", "int").add("b", "string")