Flink Capture Nachrichten basierend auf Zeitfenster und Prozess

Question

Ich möchte die Nachricht berechnen und verarbeiten mit Flink. hier liest flink daten von kafka, meine anforderung ist das lesen und verarbeiten von daten zwischen den zeitrahmen. z.

Nachrichten zwischen 12.00 Uhr bis 00.30 Uhr,

Nachricht zwischen 12.30 bis 01.00 Uhr .. und so weiter,

ich völlig neu bin flink können Sie Hilfe führen oder vorschlagen , Dokument auf diesem

Dank

Answer 1

Windowing auf dieser Seite erklärt: https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/windows.html

Konkret wird es wie folgt (als exampl aussieht e):

val windowing: DataStream[(**,**,...)] = data 
    .keyBy(?) 
    .timeWindow(Time.minutes(30)) 
    .map (// your mapping) 
    .reduce (// your reduce function here)