RuntimeConfig
API de configuration destinée à l'utilisateur, accessible via SparkSession.conf.
Prend en charge Spark Connect
Les options définies ici sont automatiquement propagées à la configuration Hadoop pendant les E/S.
Syntaxe
spark.conf.set(key, value)
spark.conf.get(key)
Propriétés
Propriété | Description |
|---|---|
Renvoie toutes les propriétés définies dans cette configuration sous forme de dictionnaire. |
Méthodes
Méthode | Description |
|---|---|
Définit la propriété de configuration d'exécution Spark donnée. | |
Renvoie la valeur de la propriété de configuration pour la clé donnée. Renvoie | |
Reset la propriété de configuration pour la clé donnée. | |
Retourne |
Exemples
Définir et récupérer une propriété de configuration :
spark.conf.set("key1", "value1")
spark.conf.get("key1")
'value1'
Récupérez une propriété avec une valeur par default :
spark.conf.get("non-existent-key", "my_default")
'my_default'
Désinitialiser une propriété de configuration :
spark.conf.set("my_key", "my_value")
spark.conf.unset("my_key")
spark.conf.get("my_key")
pyspark...SparkNoSuchElementException: ... The SQL config "my_key" cannot be found...
Récupérer toutes les propriétés de configuration :
spark.conf.set("key1", "value1")
spark.conf.set("key2", "value2")
spark.conf.getAll
{'key1': 'value1', 'key2': 'value2'}