как я могу написать искра Dataframe в clickhouse - PullRequest
Новая
       10

как я могу написать искра Dataframe в clickhouse

0 голосов
/ 28 февраля 2020 
val df = spark.read.parquet(path)
val IP ="190.176.35.145"
val port = "9000" 
val table = "table1"
val user = "defalut"
val password = "default"

Я не знаю, как написать df прямо в clickhouse, и я не могу найти аналогичного ответа. кто-нибудь, помогите мне, пожалуйста, ~

1 Ответ

2 голосов
/ 28 февраля 2020

Запись в базу данных clickhouse аналогична записи любой другой базы данных через JDB C. Просто убедитесь, что вы импортировали класс ClickHouseDriver в ваш код. Имя пользователя и пароль передаются в объект ckProperties. Команда записи выглядит следующим образом, вы можете заменить имя базы данных в строке: 

import ru.yandex.clickhouse._

val jdbcUrl = "jdbc:clickhouse://190.176.35.145:9000/your_database_name"

val ckProperties = new Properties()

df.write.mode("append").option("driver", "ru.yandex.clickhouse.ClickHouseDriver").jdbc(jdbcUrl, table = "table1", ckProperties)
...