Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Användaranpassat konfigurations-API som är tillgängligt via SparkSession.conf.
Stöder Spark Connect
Alternativ som anges här sprids automatiskt till Hadoop-konfigurationen under I/O.
Syntax
spark.conf.set(key, value)
spark.conf.get(key)
Egenskaper
| Fastighet | Beskrivning |
|---|---|
getAll |
Returnerar alla egenskaper som anges i den här konfigurationen som en diktering. |
Methods
| Metod | Beskrivning |
|---|---|
set(key, value) |
Anger den angivna konfigurationsegenskapen för Spark-körning.
value kan vara en sträng, ett heltal eller ett booleskt värde. |
get(key, default) |
Returnerar värdet för konfigurationsegenskapen för den angivna nyckeln. Returnerar default om nyckeln inte finns. Genererar ett undantag om nyckeln inte har angetts och ingen standard har angetts. |
unset(key) |
Återställer konfigurationsegenskapen för den angivna nyckeln. |
isModifiable(key) |
Returnerar True om konfigurationsegenskapen för den angivna nyckeln kan ändras i den aktuella sessionen. |
Exempel
Ange och hämta en konfigurationsegenskap:
spark.conf.set("key1", "value1")
spark.conf.get("key1")
'value1'
Hämta en egenskap med ett standardvärde:
spark.conf.get("non-existent-key", "my_default")
'my_default'
Ta bort en konfigurationsegenskap:
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...
Hämta alla konfigurationsegenskaper:
spark.conf.set("key1", "value1")
spark.conf.set("key2", "value2")
spark.conf.getAll
{'key1': 'value1', 'key2': 'value2'}