cassandra - datastax-spark カサンドラ コネクタ メソッド「joinWithCassandra」の ScalaMock

Question

Scala で datastax spark コネクタの joinWithCassandra メソッドをモックしようとしています。コンパイルでエラーが発生します。私が間違っていることを教えてください。

エラー:(59, 23) コンストラクター DStream の引数が不十分です: (ssc: org.apache.spark.streaming.StreamingContext)(暗黙の証拠 $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)])