没有可用的 ClassTag (Scala)

Question

我在 Scala 中发生了一些奇怪的事情。我正在尝试使用第三方库

org.apache.spark.streaming.kafka.KafkaUtils.createDirectStream

并获得 No ClassTag 异常。我模拟了下面的场景，因为可以将 Util 视为第三方库。为什么会这样？

object Util {
    def fun1[K: ClassTag, M: ClassTag, KD: ClassTag, MD: ClassTag]: Unit = {
        println("In function version 2")
    }
}

class ClassTagIssue[K, M, KD, MD] {
    def build: Unit = {
        Util.fun1[K, M, KD, MD]
    }
}

object ClassTagIssue {
    def main(args: Array[String]) {
        new ClassTagIssue[String, String, String, String]().build
    }
}

我正在尝试运行此代码并遇到异常

Error:(23, 14) No ClassTag available for K
    Util.fun1[K, M, KD, MD]
             ^
Error:(23, 14) not enough arguments for method fun1: (implicit evidence$1: scala.reflect.ClassTag[K], implicit evidence$2: scala.reflect.ClassTag[M], implicit evidence$3: scala.reflect.ClassTag[KD], implicit evidence$4: scala.reflect.ClassTag[MD])Unit.
Unspecified value parameters evidence$1, evidence$2, evidence$3, ...
    Util.fun1[K, M, KD, MD]
             ^

Answer 1

您必须将ClassTag 类添加为绑定到ClassTagIssue 的泛型类型的上下文。这样，您告诉编译器 K, M, KD 和 MD 类型的 ClassTags 在创建 ClassTagIssue 实例时可用。

class ClassTagIssue[K: ClassTag, M: ClassTag, KD: ClassTag, MD: ClassTag] {
  def build: Unit = {
    Util.fun1[K, M, KD, MD]
  }
}