schéma (source de données)

Renvoie le schéma de la source de données.

Il peut faire référence à tout champ initialisé dans la méthode __init__ pour inférer le schéma de la source de données lorsque les utilisateurs ne le spécifient pas explicitement. Cette méthode est invoquée une fois lors de l'appel de spark.read.format(...).load() pour obtenir le schéma d'une opération de lecture de source de données. Si cette méthode n'est pas implémentée et qu'un utilisateur ne fournit pas de schéma lors de la lecture de la source de données, une exception sera générée.

Syntaxe

schema()

Renvoie

StructType OU str

Le schéma de cette source de données ou une chaîne DDL représentant le schéma.

Exemples

Retourne une chaîne DDL :

Python

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

Renvoie un StructType:

Python

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