Створіть таблицю SQL з датафрейма
Датафрейм можна використати, щоб створити тимчасову таблицю. Тимчасова таблиця не існує після завершення сеансу. У документації Spark цей тип таблиці також називають SQL temporary view. У документації це описано як зареєструвати датафрейм як SQL temporary view. Цю команду викликають безпосередньо на датафреймі: вона створює таблицю, якщо її ще немає, або замінює її поточними даними з датафрейма, якщо така таблиця вже існує.
Ця вправа є частиною курсу
Вступ до Spark SQL у Python
Інструкції до вправи
- Завантажте дані csv з файла
trainsched.txtу датафрейм і збережіть його у зміннійdf. - Створіть тимчасову таблицю з
df. Назвіть таблицю «table1».
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# Load trainsched.txt
df = spark.____.____("trainsched.txt", header=True)
# Create temporary table called table1
df.____(____)