Ich habe einen Datenstrom von Ereignissen und einen weiteren Datenstrom von Mustern. Die Muster werden von Benutzern zur Laufzeit bereitgestellt und müssen über ein Kafka-Thema kommen. Ich muss jedes der Muster im Event-Stream mit Flink-CEP anwenden. Gibt es eine Möglichkeit, einen PatternStream aus dem DataStream zu bekommen, wenn ich das Muster vorher nicht kenne?Apache Flink: Wie man Muster aus einer Quelle auf einen anderen Datenstrom anwendet?
0
A
Antwort
1
In diesem Moment ist es nicht möglich. FlinkCEP kann nur ein Muster bearbeiten, das statisch angewendet wird. Es gibt ein JIRA-Ticket dafür: https://issues.apache.org/jira/browse/FLINK-7129, aber kann die ETA für diese Funktion nicht sagen.
Verwandte Themen
- 1. Apache Flink: Wie man mehrere Zählfensterfunktionen anwendet?
- 2. Wie füttere ich einen Apache Flink DataStream
- 3. Wie man einen einfachen Filter mit Flink in Scala anwendet
- 4. Wie konvertiert man den Datenstrom in den Datensatz in flink?
- 5. zipWithIndex auf Apache Flink
- 6. Ausgewähltes Element aus einer anderen Quelle setzen
- 7. Apache Flink - Gebrauchswerte aus einem Datenstrom, um dynamisch eine Streaming-Datenquelle zu erstellen
- 8. Apache Flink - mehrere Ausgangsleitungen
- 9. Wie man einen Hintergrund auf einer Seite anwendet?
- 10. Wie man einen Kleinbuchstabenfilter auf GridView anwendet?
- 11. Apache Flink neuen Stream dynamisch hinzufügen
- 12. Flink mit Kafka als Quelle
- 13. Wie man einen Patch auf ein Java-Projekt anwendet?
- 14. Wie aktualisiert man einen Datenstrom mit einer OpenGL-Textur?
- 15. Wie kann man den Status eines Datensatzes aus einer Datenbank in Apache Flink nachschlagen und aktualisieren?
- 16. Apache Beam/Flink ExceptionInChainedStubException
- 17. Apache-Flink KMeans Operation auf UnsortedGrouping
- 18. Elasticsearch Index als Quelle für Apache flink Batchjob
- 19. Apache flink Dataset
- 20. Wie man einen Django-Patch anwendet?
- 21. Wie teilt man einen Datenstrom in Pakete auf?
- 22. Apache Flink Logging deaktivieren
- 23. Verstehen, wie man einen Slicer auf einen Prozentsatz anwendet
- 24. Apache Flink: Schreibe einen DataStream in eine Postgres-Tabelle
- 25. Apache POI, wie man den Arbeitsbuchstil auf alle Pivot-Tabellen anwendet. Wie schließe ich Blätter aus?
- 26. Wie Apache Flink Iterationen implementieren?
- 27. Apache Flink CEP-Timout-Muster im Zeitfenster nicht definiert
- 28. Apache Flink - groupBy
- 29. Apache Flink und Ereignissequenzierung
- 30. Wie man CORS auf einen bestimmten Rest-Endpunkt anwendet
Ist es möglich, diese Logik mithilfe von Zeitfenstern zu replizieren? – wittyameta