我使用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的javaapi,状态数据被成功地检索,但是它们被编码了。
我想知道Flink如何以及在哪里对这些状态数据进行编码。
谢谢
暂无答案!
目前还没有任何答案,快来回答吧!