динамически определять имя и содержимое dataframe со списком на входе - PullRequest
0 голосов
/ 27 ноября 2018

Я написал следующую функцию:

 def extractFromInput(inputName: String, colNames: List[String]): DataFrame = {

      val inputData: List[String] = inputName.split("-").map(_.trim).toList
      inputData.foldLeft(df) {
        (df: DataFrame, columnName: String) =>
          df.withColumn(columnName, lit(columnName))

      }
    }

Я скорее хочу просмотреть список colNames и использовать его для определения имен новых столбцов с содержимым этого списка.С помощью фактической функции содержимое столбцов заполнено правильно, но я не могу сделать так, чтобы они были названы правильноЛюбая идея, как это сделать, пожалуйста

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