kafka-streams-internals-SegmentedBytesStore.adoc

SegmentedBytesStore Contract

SegmentedBytesStore is the extension of the StateStore contract for segmented-bytes state stores that FIXME.

Table 1. SegmentedBytesStore Contract

Method	Description
all	KeyValueIterator<Bytes, byte[]> all() Used when…​FIXME
fetch	KeyValueIterator<Bytes, byte[]> fetch( Bytes keyFrom, Bytes keyTo, long from, long to) KeyValueIterator<Bytes, byte[]> fetch( Bytes key, long from, long to) Used when…​FIXME
fetchAll	KeyValueIterator<Bytes, byte[]> fetchAll( long from, long to) Used when…​FIXME
get	byte[] get(Bytes key) Used when…​FIXME
put	void put( Bytes key, byte[] value) Used when…​FIXME
remove	void remove(Bytes key) Used when…​FIXME

Note	AbstractRocksDBSegmentedBytesStore is the only known direct implementation of the SegmentedBytesStore Contract in Kafka Streams.