返回数据源的架构。
它可以引用方法中 __init__ 初始化的任何字段,以在用户未显式指定数据源架构时推断数据源的架构。 调用 spark.read.format(...).load() 以获取数据源读取操作的架构时,将调用此方法一次。 如果未实现此方法,并且用户在读取数据源时不提供架构,则会引发异常。
Syntax
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")