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.

results matching ""

    No results matching ""