SparkのStreamingKMeansのクラスタセンターを見つける方法は？

Question

SparkのKMeansModelクラスを使用すると、KMeansModel.clusterCenters()関数を使用して、モデルのクラスタのセントロイドに簡単にアクセスできます。

私はStreamingKMeansを使いたかったのですが、clusterCenters()機能が不足しているようでした。 StreamingKMeansでモデルのクラスタのセントロイドを取得する方法はありますか？

Answer 1

バッチKMeansでは、推定器が1回訓練され、clusterCenters()メソッドを含むモデルである単一のトランスを生成します。 StreamingKMeansでは、モデルは継続的に更新されるため、StreamingKMeansオブジェクトでlatestModel()を使用する必要があります。

val model = new StreamingKMeans() 
     .setK(5) 
     .setDecayFactor(1.0) 
     .setRandomCenters(10, 0.0) 
val latestModel = model.latestModel() 
println(latestModel.clusterCenters)