Flink StateBackend 初探

一个StateBackEnd 包括以下几个部分： 1.CheckPointStreamFactory 构造流用于写出Checkpoint 数据 不同的StateBackEnd会有不同的实现,返回不同的CheckpointStateOutputStream实现，比如 FsStateBackEnd 就会构造文件流, 而MemoryStateBackEnd就会构造ByteArraOutputStream

>>阅读原文<<