Flink CEP 状态存储
Flink CEP state store
Flink CEP 是如何管理间歇状态的?它在哪里存储它们?
它只是在内存中还是有支持状态的快速持久存储?
文档在任何地方都没有提到这一点。
像 Flink 中的所有有状态操作(例如,windows、聚合、SQL、计时器等)一样,Flink CEP 使用 Flink's managed state. Where the working state is held, and where it is durably persisted, depends on which state backend。 RocksDB 状态后端允许状态大于适合内存的状态,并且检查点持久保存在持久存储中,例如 HDFS、S3 或 NFS。
Flink CEP 是如何管理间歇状态的?它在哪里存储它们? 它只是在内存中还是有支持状态的快速持久存储?
文档在任何地方都没有提到这一点。
像 Flink 中的所有有状态操作(例如,windows、聚合、SQL、计时器等)一样,Flink CEP 使用 Flink's managed state. Where the working state is held, and where it is durably persisted, depends on which state backend。 RocksDB 状态后端允许状态大于适合内存的状态,并且检查点持久保存在持久存储中,例如 HDFS、S3 或 NFS。