esquema (Fonte de dados)

Retorna o esquema da fonte de dados.

Pode referir-se a qualquer campo inicializado no método __init__ para inferir o esquema da fonte de dados quando os usuários não o especificam explicitamente. Este método é invocado uma vez ao chamar spark.read.format(...).load() para obter o esquema de uma fonte de dados read operações. Caso esse método não seja implementado e o usuário não forneça um esquema ao ler a fonte de dados, uma exceção será lançada.

Sintaxe

schema()

Devoluções

StructType ou str

O esquema desta fonte de dados ou uma string DDL que representa o esquema.

Exemplos

Retorna uma string DDL:

Python

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

Retorna um StructType:

Python

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