问题描述
我正在使用Flink CEP识别某些事件模式,查询看起来像
select * from $TABLE
MATCH_RECOGNIZE(
partition by $PARTITION_FIELDS
order by event_time
measures
...
one row per match
after match SKIP past LAST ROW
pattern(...) within interval '1' minute
define
...
)
我启用了RocksDB状态后端。我想检查一下RocksDB中的状态数据。通过使用RocksDB的Java API,状态数据已成功检索,但已对其进行了编码。
我想知道Flink如何以及在哪里编码这些状态数据。
谢谢
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)