schéma (DataSource)

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

Il peut faire référence à n’importe quel champ initialisé dans la __init__ méthode pour déduire le schéma de la source de données lorsque les utilisateurs ne le spécifient pas explicitement. Cette méthode est appelée une fois lors de l’appel spark.read.format(...).load() pour obtenir le schéma pour 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 est levée.

Syntaxe

schema()

Retours

StructType ou str

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

Exemples

Retourne une chaîne DDL :

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

Retourne un StructType:

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