schema (DataSource)

Devolve o esquema da fonte de dados.

Pode referir-se a qualquer campo inicializado no __init__ método para inferir o esquema da fonte de dados quando os utilizadores não o especificam explicitamente. Este método é invocado uma vez ao chamar spark.read.format(...).load() para obter o esquema de uma operação de leitura de fonte de dados. Se este método não for implementado e o utilizador não fornecer um esquema ao ler a fonte de dados, será lançada uma exceção.

Sintaxe

schema()

Devoluções

StructType ou str

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

Exemplos

Devolve uma cadeia DDL:

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

Retorna um StructType:

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