การสร้าง SparkSession
เริ่มต้นด้วยการสร้าง SparkSession ใหม่กัน ในคอร์สนี้จะมี SparkSession เตรียมไว้ให้เป็นส่วนใหญ่ แต่การสร้างขึ้นมาใหม่หรือเรียกใช้อันที่มีอยู่แล้วเป็นทักษะที่ขาดไม่ได้!
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
PySpark เบื้องต้น
คำแนะนำการฝึกหัด
- Import
SparkSessionจากpyspark.sql - สร้าง
SparkSessionใหม่ชื่อ"my_spark"โดยใช้SparkSession.builder.getOrCreate() - แสดงผล
my_sparkที่คอนโซลเพื่อตรวจสอบว่าเป็นSparkSession
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
# Import SparkSession from pyspark.sql
from ____ import ____
# Create my_spark
my_spark = SparkSession.builder.appName(____).____
# Print my_spark
____