ошибка: разделение значений не является членом Char

Question

import spark.implicits ._

case class x(Data_time_Occured:String,Duplicate_Count:Int,Message:String)

val Final_df1=Final_df.map(_.split(",")).map(x=> (x(0).trim.toString,x(1).trim.toInt,x(2).trim.toString)).toDF("Data_time_Occured","Duplicate_Count","Message")

==== Значение в fINAL_DF равно ====:
Final_df: String = 13/4/2020,0 В таблице Sql не загружены повторяющиеся записи. продолжайте следить за нагрузкой

Answer 1

Тип "Final_df" может быть изменен на Seq:

val originalString = "Data_time_Occured1,4,Message1"
val Final_df = Seq(originalString)
Final_df.map(_.split(",")).map(x => (x(0).trim.toString, x(1).trim.toInt, x(2).trim.toString)).toDF("Data_time_Occured", "Duplicate_Count", "Message")

Answer 2

Вы применяете операцию сопоставления к единственному строковому значению, а затем применяете разбиение к нему. Операция Map преобразует эту строку в отдельный символ, а затем вы пытаетесь применить опцию split для отдельного символа, поэтому вы получаете эту ошибку.

Если вы хотите разбить эту строку на запятую, вот как вы можете это сделать.

val Final_df1 = Final_df.split(",")

Это исправит вашу ошибку, а затем вы сможете применить свои преобразования для перемещения переслать согласно вашему требованию.

Пожалуйста, примите ответ, если это решит вашу проблему.