искра DataFrameWriter в последней версии

Question

Мы хотим перейти на последнюю версию spark и scala. Я довольно новичок в scala и хочу знать, как переписать приведенный ниже код, поскольку DataFrameWriter в последней версии принимает параметры типа.

Вот как мы указываем, используя старую версию.

def saveText(fs: FileSystem, path: String, writer: 
    DataFrameWriter): Unit = {
    val fullPath = fs.getFullPath(path)
    writer.text(fullPath)
}

Answer 1

В Scala, когда у вас есть параметризованный тип A[T], вы можете ссылаться на «Параметризованный чем-либо» как A[_].Следовательно, ваша функция может быть простой:

def saveText(fs: FileSystem, path: String, writer: DataFrameWriter[_]): Unit = 
  writer.text(fs.getFullPath(path))