Vytvoření SQL tabulky z dataframu
Z dataframu lze vytvořit dočasnou tabulku. Dočasná tabulka existuje pouze po dobu aktuální session – po jejím ukončení zanikne. Spark ji ve své dokumentaci označuje také jako SQL temporary view. V dokumentaci se tento postup popisuje jako registrace dataframu jako SQL temporary view. Příkaz se volá přímo na dataframu a tabulku vytvoří, pokud ještě neexistuje, nebo ji nahradí aktuálními daty z dataframu, pokud již existuje.
Toto cvičení je součástí kurzu
Úvod do Spark SQL v Pythonu
Pokyny k cvičení
- Načti CSV data ze souboru
trainsched.txtdo dataframu uloženého v proměnnédf. - Z
dfvytvoř dočasnou tabulku a pojmenuj ji „table1".
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
# Load trainsched.txt
df = spark.____.____("trainsched.txt", header=True)
# Create temporary table called table1
df.____(____)