Как достать значения датафрейма в spark и записать в строку?
Мне нужно проинсертить постгрес таблицу значениями из датафрейма. Я понимаю как вытащить название полей, подскажите как сделать тоже самое со значениями этих полей
def insertStatement(conn: Connection, table: String, df: DataFrame): PreparedStatement = {
val columns = df.schema.fields.map(_.name).mkString(",")
val values = ???
val sql = s"INSERT INTO $table VALUES ($values)"
conn.prepareStatement(sql)
}