cassandra - ScalaMock 用于 datastax-spark cassandra 连接器方法“joinWithCassandra”

Question

我试图在 Scala 中模拟来自 datastax spark 连接器的 joinWithCassandra 方法。我在编译时遇到错误。请指导我做错了什么。

错误:(59, 23) 构造函数 DStream 的参数不足: (ssc: org.apache.spark.streaming.StreamingContext)(implicit evidence$1: scala.reflect.ClassTag[Any])org.apache.spark.streaming.dstream .DStream[任何]。未指定的值参数 ssc。var mockObj = mock[DStream[Any]]

var mockObj = mock[DStream[Any]]

(mockObj.joinWithCassandraTable _).expects(sys.env.getOrElse(Config.KEY_SPACE_ENV, Config.DEFAULT_KEY_SPACE), sys.env.getOrElse(Config.DEVICE_CASSANDRA_TABLE_ENV, Config.DEFAULT_DEVICE_CASSANDRA_TABLE), SomeColumns("a", "b", "c"), SomeColumns("a")) returns(DStream[(AAAEvent, CassandraRow)])