schema (DataSource)

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

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

構文

schema()

返品

StructType または str

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

例示

DDL 文字列を返します。

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

StructTypeを返します。

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