Flink StateBackend 初探

一個StateBackEnd 包括以下幾個部分： 1.CheckPointStreamFactory 構造流用於寫出Checkpoint 數據 不同的StateBackEnd會有不同的實現,返回不同的CheckpointStateOutputStream實現，比如 FsStateBackEnd 就會構造文件流, 而MemoryStateBackEnd就會構造ByteArraOutputStream

>>阅读原文<<