Я пробую бескаркасную библиотеку для Scala и получаю сообщение "Не обнаружено никаких последствий для параметров i0: TypedColumn.Exists".Если вы можете помочь мне решить эту проблему - это было бы здорово ...
Я использую spark 2.4.0 и 0.8.0 без рамки.
Ниже приведен мой код
import org.apache.spark.sql.SparkSession
import frameless.TypedDataset
object TestSpark {
def main(args: Array[String]): Unit = {
val spark = SparkSession.builder()
.master("local[*]")
.appName("Spark Test")
.getOrCreate
import spark.implicits._
val empDS = spark.read
.option("header",true)
.option("delimiter",",")
.csv("emp.csv")
.as[Emp]
val empTyDS = TypedDataset.create(empDS)
import frameless.syntax._
empTyDS.show(10,false).run
val deptCol = empTyDS('dept) //Get the error here.`
}
}
класс дела для кода
case class Emp (
name: String,
dept: String,
manager: String,
salary: String
)