本文整理了Java中org.rocksdb.RocksDB.delete方法的一些代码示例，展示了RocksDB.delete的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。RocksDB.delete方法的具体详情如下：
包路径：org.rocksdb.RocksDB
类名称：RocksDB
方法名：delete

RocksDB.delete介绍

[英]Delete the database entry (if any) for "key". Returns OK on success, and a non-OK status on error. It is not an error if "key" did not exist in the database.
[中]删除“key”的数据库条目（如果有）。成功时返回OK，错误时返回非OK状态。如果数据库中不存在“key”，则不是错误。

代码示例

代码示例来源：origin: Alluxio/alluxio

@Override
public void remove(Long inodeId) {
 try {
  byte[] id = Longs.toByteArray(inodeId);
  mDb.delete(mInodesColumn, mDisableWAL, id);
 } catch (RocksDBException e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: Alluxio/alluxio

@Override
public void removeBlock(long id) {
 try {
  mDb.delete(mBlockMetaColumn, Longs.toByteArray(id));
 } catch (RocksDBException e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: Alluxio/alluxio

@Override
public void removeLocation(long blockId, long workerId) {
 byte[] key = RocksUtils.toByteArray(blockId, workerId);
 try {
  mDb.delete(mBlockLocationsColumn, key);
 } catch (RocksDBException e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: Alluxio/alluxio

@Override
public void removeChild(long parentId, String name) {
 try {
  mDb.delete(mEdgesColumn, mDisableWAL, RocksUtils.toByteArray(parentId, name));
 } catch (RocksDBException e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: ethereum/ethereumj

@Override
public void delete(byte[] key) {
  resetDbLock.readLock().lock();
  try {
    if (logger.isTraceEnabled()) logger.trace("~> RocksDbDataSource.delete(): " + name + ", key: " + toHexString(key));
    db.delete(key);
    if (logger.isTraceEnabled()) logger.trace("<~ RocksDbDataSource.delete(): " + name + ", key: " + toHexString(key));
  } catch (RocksDBException e) {
    logger.error("Failed to delete from db '{}'", name, e);
    throw new RuntimeException(e);
  } finally {
    resetDbLock.readLock().unlock();
  }
}

代码示例来源：origin: apache/flink

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

代码示例来源：origin: apache/flink

@Override
public void remove() {
  if (currentEntry == null || currentEntry.deleted) {
    throw new IllegalStateException("The remove operation must be called after a valid next operation.");
  }
  currentEntry.remove();
}

代码示例来源：origin: brianfrankcooper/YCSB

@Override
public Status delete(final String table, final String key) {
 try {
  if (!COLUMN_FAMILIES.containsKey(table)) {
   createColumnFamily(table);
  }
  final ColumnFamilyHandle cf = COLUMN_FAMILIES.get(table).getHandle();
  rocksDb.delete(cf, key.getBytes(UTF_8));
  return Status.OK;
 } catch(final RocksDBException e) {
  LOGGER.error(e.getMessage(), e);
  return Status.ERROR;
 }
}

代码示例来源：origin: ethereum/ethereumj

@Override
public void put(byte[] key, byte[] val) {
  resetDbLock.readLock().lock();
  try {
    if (logger.isTraceEnabled()) logger.trace("~> RocksDbDataSource.put(): " + name + ", key: " + toHexString(key) + ", " + (val == null ? "null" : val.length));
    if (val != null) {
      db.put(key, val);
    } else {
      db.delete(key);
    }
    if (logger.isTraceEnabled()) logger.trace("<~ RocksDbDataSource.put(): " + name + ", key: " + toHexString(key) + ", " + (val == null ? "null" : val.length));
  } catch (RocksDBException e) {
    logger.error("Failed to put into db '{}'", name, e);
    hintOnTooManyOpenFiles(e);
    throw new RuntimeException(e);
  } finally {
    resetDbLock.readLock().unlock();
  }
}

代码示例来源：origin: apache/flink

@Override
public void mergeNamespaces(N target, Collection<N> sources) {
  if (sources == null || sources.isEmpty()) {
    return;
  }
  try {
    // create the target full-binary-key
    setCurrentNamespace(target);
    final byte[] targetKey = serializeCurrentKeyWithGroupAndNamespace();
    // merge the sources to the target
    for (N source : sources) {
      if (source != null) {
        setCurrentNamespace(source);
        final byte[] sourceKey = serializeCurrentKeyWithGroupAndNamespace();
        byte[] valueBytes = backend.db.get(columnFamily, sourceKey);
        backend.db.delete(columnFamily, writeOptions, sourceKey);
        if (valueBytes != null) {
          backend.db.merge(columnFamily, writeOptions, targetKey, valueBytes);
        }
      }
    }
  }
  catch (Exception e) {
    throw new FlinkRuntimeException("Error while merging state in RocksDB", e);
  }
}

代码示例来源：origin: apache/flink

final byte[] sourceKey = serializeCurrentKeyWithGroupAndNamespace();
final byte[] valueBytes = backend.db.get(columnFamily, sourceKey);
backend.db.delete(columnFamily, writeOptions, sourceKey);

代码示例来源：origin: apache/flink

final byte[] sourceKey = serializeCurrentKeyWithGroupAndNamespace();
final byte[] valueBytes = backend.db.get(columnFamily, sourceKey);
backend.db.delete(columnFamily, writeOptions, sourceKey);

代码示例来源：origin: locationtech/geogig

public @Override String remove(Object key) {
  final String value = get(key);
  if (value != null) {
    try {
      db.delete(writeOptions, ((String) key).getBytes(Charsets.UTF_8));
    } catch (RocksDBException e) {
      throw new RuntimeException(e);
    }
  }
  return value;
}

代码示例来源：origin: locationtech/geogig

@Override
public void removeConflict(@Nullable String txId, String path) {
  Optional<RocksDBReference> dbRefOpt = getDb(txId);
  if (!dbRefOpt.isPresent()) {
    return;
  }
  try (RocksDBReference dbRef = dbRefOpt.get()) {
    dbRef.db().delete(key(path));
  } catch (RocksDBException e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: criccomini/ezdb

@Override
public void delete(H hashKey, R rangeKey) {
  try {
    this.db.delete(Util.combine(hashKeySerde, rangeKeySerde, hashKey,
        rangeKey));
  } catch (RocksDBException e) {
    throw new DbException(e);
  }
}

代码示例来源：origin: locationtech/geogig

@Override
public void removeBlob(String namespace, String path) {
  try (RocksDBReference dbRef = db()) {
    dbRef.db().delete(key(namespace, path));
  } catch (RocksDBException e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: pravega/pravega

@Override
public void remove(Key key) {
  ensureInitializedAndNotClosed();
  try {
    this.database.get().delete(this.writeOptions, key.serialize());
  } catch (RocksDBException ex) {
    throw convert(ex, "remove key '%s'", key);
  }
}

代码示例来源：origin: locationtech/geogig

@Override
public void delete(ObjectId objectId) {
  checkNotNull(objectId, "argument objectId is null");
  checkWritable();
  byte[] key = objectId.getRawValue();
  try (RocksDBReference dbRef = dbhandle.getReference()) {
    dbRef.db().delete(key);
  } catch (RocksDBException e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: org.apache.flink/flink-statebackend-rocksdb

@Override
public void clear() {
  try {
    writeCurrentKeyWithGroupAndNamespace();
    byte[] key = dataOutputView.getCopyOfBuffer();
    backend.db.delete(columnFamily, writeOptions, key);
  } catch (IOException | RocksDBException e) {
    throw new FlinkRuntimeException("Error while removing entry from RocksDB", e);
  }
}

代码示例来源：origin: dremio/dremio-oss

@Override
public void delete(byte[] key) {
 try (AutoCloseableLock ac = sharedLock(key)) {
  throwIfClosed();
  db.delete(handle, key);
 } catch (RocksDBException e) {
  throw wrap(e);
 }
}