apache-flink - CEP 场景下 Flink 如何对状态数据进行编码？

Question

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

谢谢