Apache Flink：如何将模式从源应用到另一个数据流？

【问题标题】：Apache Flink: How to apply patterns from a source onto another datastream?Apache Flink：如何将模式从源应用到另一个数据流？
【发布时间】：2018-06-01 16:16:29
【问题描述】：

我有一个事件数据流和另一个模式数据流。这些模式由用户在运行时提供，它们需要通过 Kafka 主题来。我需要使用 Flink-CEP 在事件流上应用每个模式。 当我事先不知道模式时，有没有办法从 DataStream 中获取 PatternStream？

【问题讨论】：

    标签： apache-flink flink-streaming flink-cep


    【解决方案1】：

    目前不可能。 FlinkCEP 只能处理一个静态应用的 Pattern。有一张 JIRA 票证：https://issues.apache.org/jira/browse/FLINK-7129，但不能告诉 ETA 这个功能。

    【讨论】：

    • 是否可以使用时间窗口复制此逻辑？
    猜你喜欢
    • 2020-10-09
    • 1970-01-01
    • 2021-08-01
    • 2018-04-27
    • 2018-09-13
    • 1970-01-01
    • 1970-01-01
    • 2016-10-10
    • 2011-04-13
    相关资源
    最近更新 更多
    热门标签
    Java Python linux javascript Mysql C# Docker 算法 前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库 数据结构 大数据 js 机器学习 微服务 Android Go 程序员 面试 JVM ASP.net core 云原生 人工智能 后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习 多线程 React 架构 devops 爬虫 云计算 Spring Boot LeetCode