flink SQL中不支持嵌套match_recognize查询？
Flink SQL是Apache Flink的一种查询语言，用于在Flink流处理引擎上执行SQL查询和分析。然而，目前的版本中，Flink SQL不支持嵌套的match_recognize查询。
match_recognize是一种用于在流数据中进行模式匹配的SQL语法，它可以用于识别和提取满足特定模式的事件序列。嵌套的match_recognize查询是指在一个match_recognize查询中嵌套另一个match_recognize查询。
尽管Flink SQL目前不支持嵌套的match_recognize查询，但仍然可以通过其他方式实现类似的功能。一种方法是使用多个独立的match_recognize查询，并在应用程序中编写逻辑来处理它们之间的关联。另一种方法是使用Flink的DataStream API来编写自定义的模式匹配逻辑。
对于Flink SQL中不支持嵌套match_recognize查询的情况，可以考虑使用其他功能强大的Flink SQL特性来实现相似的需求。例如，可以使用窗口操作、聚合函数、JOIN操作等来处理和分析流数据。
腾讯云提供了一系列与流处理和数据分析相关的产品和服务，可以与Flink SQL结合使用。例如，腾讯云的数据仓库服务TencentDB for TDSQL、流计算服务Tencent Streaming Compute等都可以与Flink SQL进行集成，提供强大的数据处理和分析能力。
更多关于腾讯云的产品和服务信息，请参考腾讯云官方网站：https://cloud.tencent.com/
相关·内容
默认情况下，CEP中的interval ...应该定义一个滚动窗口。是否可能有一个跳转窗口用于CEP模式匹配？或者其他的解决方案？
谢谢
浏览 3提问于2021-03-11得票数 0
回答已采纳
我正在使用flink 1.11并尝试嵌套查询，其中包含match_recognize，如下所示：
select * from events where id = (SELECT * FROM eventsMATCH_RECOGNIZE (PARTITION BY org_id ORDER BY proctime MEASURES A.id AS startId ONE ROW PER MATCH PATTERNDEFINE A AS A.tag = 'tag1', C AS C.tag
浏览 39提问于2021-05-12得票数 0
回答已采纳
1回答
有没有办法以可共享的格式(例如Json)指定Apache Flink CEP模式？
我的用例是:开发一个规则引擎，允许用户在不编写大量Java代码的情况下定制CEP模式，并轻松地与其他人共享模式。
浏览 2提问于2018-12-11得票数 0
2回答
我在一个带有几个CTE的查询中使用MATCH_RECOGNIZE函数。当我运行查询时，我得到了以下错误：SELECT
浏览 0提问于2021-07-27得票数 1
回答已采纳
我曾试图解决这个问题： SELECT * from event_with_eventReference> PARTITION BY eventMridMATCH&
浏览 14提问于2022-07-20得票数 0
我想从SQL客户端试用Flink SQL中的Match_Recognize操作符。type: source connector: path: "/home/bitnami/Match_Recognizeat org.apache.flink.table.client.SqlClient.validateEnviron
浏览 1提问于2020-02-13得票数 0
当我尝试在使用Python的SQL查询中使用MATCH_RECOGNIZE时，我会得到错误Python Function can not be used in MATCH_RECOGNIZE for now例如，不支持以下内容：FROM MyTable ORDER BY proctime A.a as在文档中，我在哪里可以找到这种缺乏支持的情况？关于这个特性的没有
浏览 4提问于2021-07-26得票数 0
我正在组合一个有点复杂的查询，以便在雪花中使用大型时间序列数据集进行事件检测、连接和基于时间的绑定。我最近注意到，match_recognize允许我雄辩地检测时间序列事件，但是每当我试图在公共表表达式(with .. as ..)中使用match_recognize表达式时，我都会收到以下错误：SQL编译错误:在此上下文中不支持MATCH_RECOGNIZE。我已经做了大量的搜索/阅读，但没有发现在CTE中关于match_recognize
浏览 2提问于2021-06-29得票数 3
回答已采纳
1回答
我在Flink SQL中使用CEP模式，它正在按预期工作，连接到Kafka broker。但是当我连接到基于集群的云kafka设置时，Flink CEP并没有触发。以下是我的sql：( room_id String, select * from agent_action_de
浏览 1提问于2021-10-25得票数 0
回答已采纳
我是flink的新手，想了解如何使用FLINK运行我的用例:应用程序有三个输入数据源a)历史数据b)从kafka获取所有实时事件c)获取将具有触发条件的控制事件 由于应用程序正在处理历史数据，因此我认为我将合并历史数据和实时数据要触发事件，我们必须在控制事件的帮助下编写SQL查询，该事件是输入源，并且包含where子句。我的问题是在数据位于Stream中时构建SQL查询，并且当我执行以下操作时 DataStream<ControlEvent> control
浏览 37提问于2020-07-01得票数 1
rowtime，我将它注册为一个表：然后我查询表： "SELECT tumble_start(_time, interval '10' second) as timestart, " +"GROUP BY tumble(_time, interval &
浏览 1提问于2018-03-02得票数 1
这里的挑战是，在普通CEP中，我们将值与常量(如"event“= login )进行比较。在这种情况下，标准是不同的，就像在蛮力攻击的情况下，我们有如下的标准。
浏览 4提问于2020-09-29得票数 0
1回答
我需要计算一天中A发生的次数，以及15分钟内B发生的次数。流可以是A1、A2、B1、B2、A3、B3、B4、B5、A4、A5、A6、A7、B6。在我的例子中，事件结果是A2，B1 A3，B3 A7，B6。当匹配发生时，我需要接收实时结果。我有点累了。我认为只有使用flink cep才能做到这一点。但是flink-sql-cep不支持聚合。在这种情况下，如何使用单个SQL完成此任务。
我试了两个步骤，我先用flink sql cep来匹
浏览 0提问于2019-10-12得票数 0
2回答
嗨，我计划使用flink作为我的功能的后端，我们将向用户展示一个用户界面，以图形化的方式创建事件模式，例如:来自同一个Ip地址的多个登录失败。我们将使用UI中的用户指定的条件以编程方式创建flink模式。对于这种使用apache的用例，有什么最佳实践吗？
浏览 9提问于2021-12-21得票数 1
我在Apache Flink中创建了一个Apache Flink，并创建了一个加载数据的Table对象。现在我想找一些模式。我正在用做这件事。下面查询的任务是查找mGroup的最长时间段，而avgResult没有低于某个阈值。其中mGroup是Integer值，如100、200、300等。Avgresult是双值。在编译查询部分时，不会出现任何错误。当我将Table转换为DataSet<row>时，会得到错误信息。下面的查询u可以看到错误消息。trendTable = tab
浏览 2提问于2019-10-21得票数 0
回答已采纳
2回答
Flink的嵌套输出
、、、
我正在使用Flink SQL处理Kafka流，其中每条消息都是从kafka中提取的，使用flink sql处理，然后推回到Kafka中。我想要一个嵌套的输出，其中输入是扁平的，输出是嵌套的。使用Apache Flink SQL API可以做到这一点吗？如有必要，可以使用用户定义的函数，但要避免这样做。
浏览 56提问于2019-01-04得票数 0
已尝试以下查询： SELECT key, value, ROW_NUMBER() OVER w AS rn WINDOWINTERVAL '15' MINUTE) ORDER BY -ts)不幸的是，这会导致异常
org.apache.flink.table.planner.codegen.CodeGenException
浏览 0提问于2020-05-30得票数 0
是否可以在外部查询现有的StreamTable，而不上传.jar获取执行环境和检索表环境？由于Apache表1.4的动态(连续)表特性，我一直在等待它的发布。为了执行一些活动查询，而不是在数据流之上定义(连续的或仅附加的)数据库视图。我知道我可以将我的表导出到一些数据库中，并使用SQL动态查询这个数据库，但这是一种尴尬的行为。Flink的美妙之处在于，一切都是实时的，所有的东西都是流，那么是否可以从外部程序实时查询Flink表呢？
浏览 5提问于2017-10-25得票数 2
回答已采纳
我知道德鲁伊有scala/php客户端，但我使用的是java，我不想直接通过HTTP查询德鲁伊DB，有可用的java德鲁伊客户机吗？
浏览 3提问于2017-10-09得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
