flink-cep

0Hitze

2Antwort

Warum können dieselben Ereignisse eines PatternStream sowohl an die PatternSelectFunction als auch an die PatternTimeoutFunction gesendet werden?

Ich muss 3 Ereignisse in 3 Kafka-Streams sammeln, die die gleiche correlationId in einer bestimmten Zeit haben, und in der Lage sein, alle oder einen Teil dieser Ereignisse zu sammeln, wenn sie zu spä

0Hitze

1Antwort

Sendedatenstrom von VM-Buchse/Remote-Buchse an Flink Programm läuft auf Host-OS

Wie in Flink Dokumentation erwähnt, konnte ich die Texteingabe von Textserver lesen, indem eine lokale Socket mit [email protected]:~$ nc -l 12345 öffnen und dann empfangen es auf Flink Programm Dat

0Hitze

2Antwort

Flink Avro 1.8.1 NoSuchMethodError beim Ausführen auf Cluster

Wir führen Flink 1.3.0 CEP-Jobs und verlassen uns auf Avro 1.8.1 (LogicalType existiert nicht in Avro 1.7.7), um komplexe Ereignisse (als POJOs) zu serialisieren. Es funktioniert, wenn aus der IDE (In

0Hitze

1Antwort

Gibt es ein Apache Flink Tutorial zum maschinellen Lernen in Java?

Ich bin auf der Suche nach einem Tutorial, das uns auffordert, ein grundlegendes Apache Flink Machine Learning einzurichten. Aktuelle avilable Material ist in Scala Sprache.

1Hitze

2Antwort

Flink Complex Event Processing

Ich habe einen Flink Cep-Code, der vom Socket liest und nach einem Muster erkennt. Sagen wir, das Muster (Wort) ist "Alarm". Wenn der Wortalarm fünf Mal oder öfter auftritt, sollte eine Warnung erstel

2Hitze

1Antwort

Flink CEP: Welche Methode zum Verbinden von Datenströmen für verschiedene Arten von Ereignissen?

Angenommen, ich habe zwei verschiedene Arten von Datenströmen, einen für Wetterdaten und den anderen für Fahrzeugdaten, und ich möchte mit Flink komplexe Ereignisverarbeitung für die Daten durchführen

1Hitze

1Antwort

flink Streaming erstellen Datei (CSV oder Text) auf Zeitfenster

: Ich bin zu flink Ich habe Transformation annehmen, wie dies val supportTask= customSource .map(line => line.split(",")) .map(line => SupportTaskNew(line(0)toInt,line(1).toString,line(2)to

1Hitze

1Antwort

Flink Streaming AWS S3 lesen mehrere Dateien parallel

Ich bin neu in Flink, mein Verständnis ist folgende API-Aufruf StreamExecutionEnvironment.getExecutionEnvironment().readFile(format, path) werden die Dateien parallel zur gegebenen S3 Schaufelbahn l

1Hitze

1Antwort

Dynamic Stream SQL für Apache Flink CEP

Ich möchte Stream-SQL in Kafka setzen, um von Flink für CEP verbraucht werden. Ist das ein guter Weg? Ich weiß, dass dynamische Musterdefinition ist nicht erlaubt auf Flink und ich muss Regeln anwende

1Hitze

1Antwort

Ist es möglich, mehrere Streams in Apache Flink CEP zu verarbeiten?

Meine Frage ist, dass, wenn wir zwei rohe Ereignisströme, dh Smoke und Temperatur und wir wollen, um herauszufinden, ob komplexes Ereignis dh Feuer durch Operatoren auf rohe Ströme geschehen ist, könn