Блоки данных: функция с фреймом данных в качестве параметра (SCALA) - PullRequest
Новая
       14

Блоки данных: функция с фреймом данных в качестве параметра (SCALA)

0 голосов
/ 27 июня 2019

Как создать функцию, в которой в качестве параметра указан фрейм данных? Я столкнулся со следующей проблемой enter image description here

Как решить ?? Я пытался "Dataframe", но все еще не в порядке

1 Ответ

0 голосов
/ 05 июля 2019

@ MichaelChau Я рекомендую провести небольшое исследование, прежде чем публиковать ваш вопрос, люди, как правило, реагируют лучше, если вы можете продемонстрировать работу, которую вы уже проделали, чтобы попытаться решить вашу проблему.При этом (и я сожалею, что это немного поздно), следующий код должен ответить на ваш вопрос: 

%scala // sets the command language to scala, I'm testing this in a python notebook ?

import org.apache.spark.sql.DataFrame // this imports the DataFrame type

def writeToSQLWarehouse (df: DataFrame, tableName: String, mode: String) = {
  // I didn't write out all the options, but this should give you a starting place
  df.write
  .option("dbTable", tableName)
  .mode(mode)
  .save()
}

Я получил эту информацию со страницы документации базы данных .Проверьте это, если у вас есть какие-либо дополнительные вопросы.

...