Sie können mit einem StateDStream dafür. Es ist ein Beispiel Stateful Wortzahl von Funken Beispielen .
Die Funktionsweise ist, dass Sie eine Seq[T] für jede Charge zu erhalten, dann aktualisieren Sie ein Option[T] , die wie ein Akkumulator wirkt. Der Grund ist es ein Option ist, weil auf der ersten Charge wird% betragen co_de% und auch so bleiben, wenn es aktualisiert wird. In diesem Beispiel ist die Zählung ein int, wenn Sie mit einer Menge von Daten zu tun mögen Sie vielleicht sogar ein None oder Long