Spark Streaming Window Breite und Folie

Question

Ich wollte Funken-Streaming verwenden, um Ereignisse von Kafka verarbeiten und die Fensterbreite und Folie in Bezug auf die Anzahl der Nachrichten anstelle der Zeit zu setzen. Ist das möglich? Ich habe in der API dafür nichts Offensichtliches gesehen und stattdessen nur zeitbasierte Fensteroptionen gesehen.

Answer 1

Das ist nicht möglich. Sie können nur die Fensterdauer festlegen.

Answer 2

Die nahe genug bekommt, was ich möchte: [Ausgabe ein Ereignis in einer Reihe von Nachrichten innerhalb eines bestimmten Zeitraums basiert] https://damieng.com/blog/2015/06/27/time-window-events-with-apache-spark-streaming