Vytvoření SparkSession
Už jsme pro tebe připravili SparkSession s názvem spark, ale co kdybys si nebyl/a jistý/a, jestli už nějaká existuje? Vytváření více SparkSession a SparkContext může způsobovat problémy, takže osvědčeným postupem je použít metodu SparkSession.builder.getOrCreate(). Ta vrátí existující SparkSession, pokud už v prostředí nějaká je, nebo v případě potřeby vytvoří novou!
Toto cvičení je součástí kurzu
Foundations of PySpark
Pokyny k cvičení
- Importuj
SparkSessionzpyspark.sql. - Vytvoř novou
SparkSessions názvemmy_sparkpomocíSparkSession.builder.getOrCreate(). - Vypiš
my_sparkdo konzole a ověř, že jde oSparkSession.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
# Import SparkSession from pyspark.sql
from ____ import ____
# Create my_spark
my_spark = ____
# Print my_spark
print(____)