Spark.streaming.mapWithState の「更新関数」の単体テストを作成し、「org.apache.spark.streaming.State」パラメーターをモックする必要がありますが、それはシールされたクラスであり、コンパイラーは例外について不平を言います: シールからの不正な継承クラス状態。自分の機能をどのようにテストすればよいですか?
Spark.streaming.mapWithState の「更新関数」の単体テストを作成し、「org.apache.spark.streaming.State」パラメーターをモックする必要がありますが、それはシールされたクラスであり、コンパイラーは例外について不平を言います: シールからの不正な継承クラス状態。自分の機能をどのようにテストすればよいですか?