Мы читаем данные из таблицы hive
с hiveContext
, используя spark dataframe
. После выполнения некоторых агрегаций данных мы сохраняем эти данные в другой таблице (в которой уже есть данные). Но новые данные не добавляются в существующую таблицу... и не показывают никаких ошибок...
Примечание. Перед сохранением в hive
я могу распечатать файл dataframe
.