เริ่มต้นใช้งานเริ่มต้นใช้งานได้ฟรี

สร้างตาราง SQL จาก dataframe

dataframe สามารถนำมาใช้สร้าง temporary table ได้ Temporary table คือตารางที่จะหายไปเมื่อสิ้นสุด session เอกสารของ Spark เรียกตารางประเภทนี้ว่า SQL temporary view ในเอกสารจะใช้คำว่า register the dataframe as a SQL temporary view คำสั่งนี้เรียกใช้งานผ่าน dataframe โดยตรง และจะสร้างตารางใหม่หากยังไม่มี หรือแทนที่ตารางเดิมด้วยข้อมูลปัจจุบันจาก dataframe หากมีอยู่แล้ว

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร

Introduction to Spark SQL in Python

ดูคอร์ส

คำแนะนำการฝึกหัด

  • โหลดข้อมูล CSV จากไฟล์ trainsched.txt เข้าสู่ dataframe แล้วเก็บไว้ในตัวแปรชื่อ df
  • สร้าง temporary table จาก df และตั้งชื่อตารางว่า "table1"

แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ

ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์

# Load trainsched.txt
df = spark.____.____("trainsched.txt", header=True)

# Create temporary table called table1
df.____(____)
แก้ไขและรันโค้ด