schema (DataSource)

Veri kaynağının şemasını döndürür.

Kullanıcılar açıkça belirtmediğinde veri kaynağının __init__ şemasını çıkarsamak için yönteminde başlatılan herhangi bir alana başvurabilir. Bir veri kaynağı okuma işlemi için şemayı almak üzere çağrılırken spark.read.format(...).load() bu yöntem bir kez çağrılır. Bu yöntem uygulanmazsa ve bir kullanıcı veri kaynağını okurken bir şema sağlamazsa, bir özel durum oluşturulur.

Sözdizimi

schema()

İadeler

StructType veya str

Bu veri kaynağının şeması veya şemayı temsil eden bir DDL dizesi.

Örnekler

Bir DDL dizesi döndürür:

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

bir StructTypedöndürür:

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