esquema (DataSource)

Retorna o esquema da fonte de dados.

Ele pode se referir a qualquer campo inicializado no __init__ método para inferir o esquema da fonte de dados quando os usuários não o especificam explicitamente. Esse método é invocado uma vez ao chamar spark.read.format(...).load() para obter o esquema de uma operação de leitura da fonte de dados. Se esse método não for implementado e um usuário não fornecer um esquema ao ler a fonte de dados, uma exceção será gerada.

Sintaxe

schema()

Devoluções

StructType ou str

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

Exemplos

Retorna uma cadeia de caracteres DDL:

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

Retorna um StructType:

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