org.apache.flink.contrib.streaming.state

Class RocksDBWriteBatchWrapper

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksDBWriteBatchWrapper

All Implemented Interfaces:

AutoCloseable

public class RocksDBWriteBatchWrapper
extends Object
implements AutoCloseable

It's a wrapper class around RocksDB's WriteBatch for writing in bulk.

IMPORTANT: This class is not thread safe.

Constructor Summary

Constructors

Constructor and Description
RocksDBWriteBatchWrapper(org.rocksdb.RocksDB rocksDB)
RocksDBWriteBatchWrapper(org.rocksdb.RocksDB rocksDB, org.rocksdb.WriteOptions options)
RocksDBWriteBatchWrapper(org.rocksdb.RocksDB rocksDB, org.rocksdb.WriteOptions options, int capacity)

Method Summary

Modifier and Type	Method and Description
void	close()
void	flush()
org.rocksdb.WriteOptions	getOptions()
void	put(org.rocksdb.ColumnFamilyHandle handle, byte[] key, byte[] value)
void	remove(org.rocksdb.ColumnFamilyHandle handle, byte[] key)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RocksDBWriteBatchWrapper

public RocksDBWriteBatchWrapper(@Nonnull
                                org.rocksdb.RocksDB rocksDB)

RocksDBWriteBatchWrapper

public RocksDBWriteBatchWrapper(@Nonnull
                                org.rocksdb.RocksDB rocksDB,
                                @Nullable
                                org.rocksdb.WriteOptions options)

RocksDBWriteBatchWrapper

public RocksDBWriteBatchWrapper(@Nonnull
                                org.rocksdb.RocksDB rocksDB,
                                @Nullable
                                org.rocksdb.WriteOptions options,
                                int capacity)

Method Detail

put

public void put(@Nonnull
                org.rocksdb.ColumnFamilyHandle handle,
                @Nonnull
                byte[] key,
                @Nonnull
                byte[] value)
         throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

remove

public void remove(@Nonnull
                   org.rocksdb.ColumnFamilyHandle handle,
                   @Nonnull
                   byte[] key)
            throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

flush

public void flush()
           throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

getOptions

public org.rocksdb.WriteOptions getOptions()

close

public void close()
           throws org.rocksdb.RocksDBException

Specified by:

close in interface AutoCloseable

Throws:

org.rocksdb.RocksDBException