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 merupakan bagian dari kursus
Dasar-Dasar PySpark
Instruksi latihan
- Impor
SparkSessiondaripyspark.sql. - Buat
SparkSessionbaru bernamamy_sparkmenggunakanSparkSession.builder.getOrCreate(). - Cetak
my_sparkke konsol untuk memverifikasi bahwa itu adalahSparkSession.
Latihan interaktif langsung praktik
Cobalah latihan ini dengan melengkapi kode contoh ini.
# Import SparkSession from pyspark.sql
from ____ import ____
# Create my_spark
my_spark = ____
# Print my_spark
print(____)