skema (DataSource)

Mengembalikan skema sumber data.

Ini dapat merujuk ke bidang apa pun yang __init__ diinisialisasi dalam metode untuk menyimpulkan skema sumber data ketika pengguna tidak secara eksplisit menentukannya. Metode ini dipanggil sekali saat memanggil spark.read.format(...).load() untuk mendapatkan skema untuk operasi baca sumber data. Jika metode ini tidak diimplementasikan, dan pengguna tidak memberikan skema saat membaca sumber data, pengecualian akan dilemparkan.

Sintaksis

schema()

Pengembalian Barang

StructType atau str

Skema sumber data ini atau string DDL yang mewakili skema.

Examples

Mengembalikan string DDL:

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

Mengembalikan :StructType

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