code: @Override
  	public void clear() {
  		try {
  			backend.db.delete(columnFamily, writeOptions, serializeCurrentKeyWithGroupAndNamespace());
  		} catch (RocksDBException e) {
  			throw new FlinkRuntimeException("Error while removing entry from RocksDB", e);
  		}
  	}
docs: ------------------------------------------------------------------------