Как использовать эту функцию pyspark: insertInto (tableName, overwrite = False)? - PullRequest
0 голосов
/ 24 сентября 2019

Мне нужно вставить данные из фрейма данных в таблицу на существующей таблице Postgres DB, используя PySpark.Я нашел это утверждение в официальной документации PySPark:

insertInto (tableName, overwrite = False)

Объяснение: Вставляет содержимое DataFrame в указанную таблицу.Требуется, чтобы схема класса: DataFrame совпадала со схемой таблицы.При желании можно перезаписать любые существующие данные.

Может кто-нибудь дать мне пример этой функции?Заранее спасибо

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...