schema (DataSource)

Devuelve el esquema del origen de datos.

Puede hacer referencia a cualquier campo inicializado en el __init__ método para deducir el esquema del origen de datos cuando los usuarios no lo especifican explícitamente. Este método se invoca una vez al llamar spark.read.format(...).load() a para obtener el esquema de una operación de lectura del origen de datos. Si no se implementa este método y un usuario no proporciona un esquema al leer el origen de datos, se producirá una excepción.

Sintaxis

schema()

Devoluciones

StructType o str

El esquema de este origen de datos o una cadena DDL que representa el esquema.

Ejemplos

Devuelve una cadena DDL:

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

Devuelve un StructTypeobjeto :

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