apache-flink, Seitenzahl 1

Apache Flink ist eine Open-Source-Plattform für skalierbare Batch- und Stream-Datenverarbeitung. Flink unterstützt Batch- und Streaming-Analysen in einem System. Analytische Programme können in kurzen und eleganten APIs in Java und Scala geschrieben werden.

Antwort

So kombinieren Sie Streaming-Daten mit großen Verlaufsdaten in Dataflow / Beam

Ich untersuche Verarbeitungsprotokolle von Web-Benutzersitzungen über Google Dataflow / Apache Beam und muss die Logs der Benutzer beim Eintreffen (Streaming) mit dem Verlauf einer Benutzersitzung aus dem letzten Monat kombinieren. Ich habe m...

29.04.2016, 00:21

Antworten

Was sind die Unterschiede zwischen Hazelcast Jet und Apache Flink?

Genauer gesagt, welche Anwendungsfälle löst Hazelcast Jet, die Flink nicht (gleich gut) löst und umgekehrt?

15.02.2017, 07:43

Antwort

Flink Streaming-Ereignis Zeitfenster Bestellung

Ich stoße auf einige Probleme, die die Semantik rund um das Fenster der Ereigniszeit verstehen. Das folgende Programm generiert einige Tupel mit Zeitstempeln, die als Ereigniszeit verwendet werden und eine einfache Fensteraggregation durchführen...

08.12.2015, 19:04

Antwort

Was bedeutet "Streaming" in Apache Spark und Apache Flink?

Als ich zur Webseite von Apache Spark Streaming ging, sah ich einen Satz: Spark Streaming macht es einfach, skalierbare fehlertolerante Streaming-Anwendungen zu erstellen. Und in der Apache Flink Website gibt es einen Satz: A...

30.06.2015, 10:13

Antwort

Wie können einzelne Wörter in einem Stream gezählt werden?

Gibt es eine Möglichkeit, die Anzahl eindeutiger Wörter in einem Stream mit Flink Streaming zu zählen? Die Ergebnisse wären ein Zahlenstrom, der ständig zunimmt.

31.03.2016, 18:04

Antwort

Wie kann man den Status eines Datensatzes aus einer Datenbank in Apache Flink nachschlagen und aktualisieren?

Ich arbeite an einer Daten-Streaming-Anwendung und untersuche die Möglichkeit, Apache Flink für dieses Projekt zu verwenden. Der Hauptgrund dafür ist, dass es nette High-Level-Streaming-Konstrukte unterstützt, die der Stream-API von Java 8 sehr...

10.08.2016, 06:45

Antwort

flink Job wird nicht auf mehrere Rechner verteilt

Ich habe einen kleinen Anwendungsfall in Apache flink, das ist ein Batch-Verarbeitungssystem. Ich muss eine Sammlung von Dateien verarbeiten. Die Verarbeitung jeder Datei muss von einem Computer ausgeführt werden. Ich habe das unter dem Code. Di...

04.05.2017, 09:53