首页 > 解决方案 > 未找到参数 i0 的隐含:TypedColumn.Exists

问题描述

我正在尝试 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
)

标签: scalaapache-sparkframeless

解决方案


推荐阅读