我是Akka/Scala的新手,正在尝试调试下面的代码。当resultSetParser有一个例外时,它不会抛出它。相反,使用此代码的服务只是永远闲置。 如何让我的服务抛出异常,而不仅仅是在流中等待?在Akka中有没有类似watchException()的函数,我可以在watchTermination()之后调用它,使它在处理流时看到异常? val chunkSource: Source[Chun
我想知道与群集中心关联的ID是什么。 model.transform(dataset)将为我的数据点分配预测的群集ID,并且model.clusterCenters.foreach(println)将打印这些群集中心,但我无法弄清楚如何将群集中心与其ID相关联。 import org.apache.spark.ml.clustering.KMeans
// Loads data.
val d
我有以下情况: + DentistApp
L TreatsLibrary
L IceCream 1.0
L CavityCausesLib
L IceCream 2.0
现在,我得到一个VerifyError因为TreatsLibrary使用IceCream.giveToKidAfterDrill()这是在2.0版本中删除的,因为法律上的原因。 如何导入