Package org.apache.kafka.streams.state.internals

Interface BatchWritingStore

All Known Subinterfaces:

Segment

All Known Implementing Classes:

RocksDBStore, RocksDBTimestampedStore

public interface BatchWritingStore

Method Summary

Modifier and Type	Method	Description
void	addToBatch(KeyValue<byte[],byte[]> record, org.rocksdb.WriteBatch batch)
void	write(org.rocksdb.WriteBatch batch)

Method Detail

addToBatch

void addToBatch(KeyValue<byte[],byte[]> record,
                org.rocksdb.WriteBatch batch)
         throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

write

void write(org.rocksdb.WriteBatch batch)
    throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException