HDFSBackedStateStoreProvider — Default StateStoreProvider
HDFSBackedStateStoreProvider — Default StateStoreProvider
HDFSBackedStateStoreProvider — Default StateStoreProvider
StateStoreProvider Contract StateStoreProvider is the abstraction of state store providers that manage StateStores ...
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