flink如何在cep场景中编码状态数据?

vjrehmav  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(213)

我使用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如何以及在哪里对这些状态数据进行编码。
谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题