MemoryStateStore
MemoryStateStore MemoryStateStore is…FIXME
MemoryStateStore MemoryStateStore is…FIXME
HDFSBackedStateStore — State Store on HDFS-Compatible File System
StateStore Contract — Kay-Value Store for State Management
OffsetSeqMetadata OffsetSeqMetadata holds the metadata for…FIXME: batchWatermarkMs - the current ...
OffsetSeq OffsetSeq is…FIXME OffsetSeq is created when…MEFIXME toStreamProgress Met ...
OffsetSeqLog — HDFSMetadataLog with OffsetSeq Metadata
CompactibleFileStreamLog
CommitLog — HDFSMetadataLog for Batch Completion Log
HDFSMetadataLog — MetadataLog with Hadoop HDFS for Reliable Storage
MetadataLog — Contract for Metadata Storage