Membuat SparkSession
Kami sudah membuat SparkSession untuk Anda bernama spark, tetapi bagaimana jika Anda tidak yakin apakah sudah ada? Membuat banyak SparkSession dan SparkContext dapat menimbulkan masalah, jadi praktik terbaik adalah menggunakan metode SparkSession.builder.getOrCreate(). Metode ini akan mengembalikan SparkSession yang sudah ada di lingkungan jika tersedia, atau membuat yang baru jika diperlukan!
Latihan ini adalah bagian dari kursus
Dasar-Dasar PySpark
Petunjuk latihan
- Impor
SparkSessiondaripyspark.sql. - Buat
SparkSessionbaru bernamamy_sparkmenggunakanSparkSession.builder.getOrCreate(). - Cetak
my_sparkke konsol untuk memverifikasi bahwa itu adalahSparkSession.
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
# Import SparkSession from pyspark.sql
from ____ import ____
# Create my_spark
my_spark = ____
# Print my_spark
print(____)