flink-cep

0Hitze

1Antwort

scala - kann Symbol nicht auflösen Karte

Ich schreibe einen einfachen Code zu testen CEP library in Scala, maven Abhängigkeit Version 1.1-SNAPSHOT. Mein Code: val res = igd.filter(_._2 == 13) val pattern: Pattern[(Long,String,String,Long),

2Hitze

2Antwort

Apache Flink Union Operator geben falsche Antwort

Ich bin Union-Operator auf zwei DataStream s Generische Datensatztyp anwenden. package com.gslab.com.dataSets; import java.io.File; import java.util.ArrayList; import java.util.List; import org.ap

4Hitze

1Antwort

Flink Tabellen-API DataSet Datastream zu konvertieren

Ich verwende Flink Tabellen-API unter Verwendung von Java nicht in der Lage, wo ich DataSet Datastream konvertieren möchten .... Im Anschluss ist mein Code: TableEnvironment tableEnvironment=new Table

1Hitze

1Antwort

Ho kann ich ein faules Spiel mit Flink CEP machen

Ich möchte mit FlinkCEP nur ein "faules" Spiel auf einem Muster machen. Wie kann ich das machen? z.B. Ich habe einen Eingabestrom ACABCABCB und ich möchte auf A gefolgt von C übereinstimmen, um nur 3

1Hitze

2Antwort

Wie Sie verschiedene log4j.properties-Dateien für verschiedene flink-Jobs angeben, die auf demselben Standalone-Cluster ausgeführt werden

Ich habe mehrere flink-Jobs auf einem eigenständigen Cluster ausgeführt. Ich möchte verschiedene Protokolldateien für verschiedene Flink-Jobs. Also, wie kann ich verschiedene log4j.properties Datei üb

1Hitze

1Antwort

Apache Flink CEP-Timout-Muster im Zeitfenster nicht definiert

Ich verwende PatternTimeoutFunction, um die Ereignissequenz zu verwerfen, wenn sie außerhalb des definierten Zeitfensters liegt. ich das Wasserzeichen setze als public Watermark checkAndGetNextWaterma