Когда я пытаюсь сделать то же самое в своем коде, как указано ниже
dataframe.map(row => {
val row1 = row.getAs[String](1)
val make = if (row1.toLowerCase == "tesla") "S" else row1
Row(row(0),make,row(2))
})
Я взял приведенную выше ссылку здесь: Scala: как заменить значение в Dataframs с помощью scala Но я получаю ошибку кодировщика как
Невозможно найти кодировщик для типа, хранящегося в наборе данных. Примитивные типы (Int, S tring и т.д.) И Типы продуктов (классы case) поддерживаются импорт spark.im plicits._ Поддержка сериализации других типов будет быть добавлен в будущих выпусках.
Примечание. Я использую искру 2.0!