ÎncepețiÎncepe gratuit

Creează o tabelă SQL dintr-un dataframe

Un dataframe poate fi folosit pentru a crea o tabelă temporară. O tabelă temporară este una care nu va mai exista după încheierea sesiunii. Documentația Spark mai numește acest tip de tabelă și view temporar SQL. În documentație, acest proces este descris ca înregistrarea dataframe-ului ca view temporar SQL. Comanda se apelează direct pe dataframe și creează tabela dacă aceasta nu există deja, înlocuind-o cu datele curente din dataframe dacă există deja.

Acest exercițiu face parte din cursul

Introducere în Spark SQL în Python

Vezi cursul

Instrucțiuni pentru exercițiu

  • Încarcă datele CSV din fișierul trainsched.txt într-un dataframe stocat într-o variabilă numită df.
  • Creează o tabelă temporară din df. Numește tabela "table1".

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

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

# Create temporary table called table1
df.____(____)
Editează și rulează codul