org.rocksdb.RocksDB.remove()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(6.1k)|赞(0)|评价(0)|浏览(189)

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

RocksDB.remove介绍

[英]Remove 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: alibaba/jstorm

  1. @Override
  2. public void remove(String key) {
  3.   try {
  4.     db.remove(key.getBytes());
  5.   } catch (Exception e) {
  6.     LOG.error("Failed to remove " + key);
  7.   }
  8. }

代码示例来源：origin: alibaba/jstorm

  1. @Override
  2. public void remove(K key) throws IOException {
  3.   try {
  4.     rocksDb.remove(columnFamily, serializer.serialize(key));
  5.   } catch (RocksDBException e) {
  6.     throw new IOException(String.format("Failed to remove key=%s", key), e);
  7.   }
  8. }

代码示例来源：origin: ltsopensource/light-task-scheduler

  1. @Override
  2. public void delete(String key) throws FailStoreException {
  3.   try {
  4.     db.remove(key.getBytes("UTF-8"));
  5.   } catch (Exception e) {
  6.     throw new FailStoreException(e);
  7.   }
  8. }

代码示例来源：origin: ltsopensource/light-task-scheduler

  1. @Override
  2. public void delete(String key) throws FailStoreException {
  3.   try {
  4.     db.remove(key.getBytes("UTF-8"));
  5.   } catch (Exception e) {
  6.     throw new FailStoreException(e);
  7.   }
  8. }

代码示例来源：origin: alibaba/jstorm

  1. @Override
  2. public Object get(String key) {
  3.   try {
  4.     byte[] data = db.get(key.getBytes());
  5.     if (data != null) {
  6.       try {
  7.         return deserialize(data);
  8.       } catch (Exception e) {
  9.         LOG.error("Failed to deserialize obj of " + key, e);
  10.         db.remove(key.getBytes());
  11.         return null;
  12.       }
  13.     }
  14.   } catch (Exception ignored) {
  15.   }
  16.   return null;
  17. }

代码示例来源：origin: alibaba/jstorm

  1. } catch (Exception e) {
  2.   LOG.error("Failed to deserialize obj of " + new String(keyByte));
  3.   db.remove(keyByte);
  4.   continue;

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

  1. getRocksDB().remove(storeHandle, key.get());
  2.   return true;
  3. } else {
  4.     getRocksDB().remove(storeHandle, key.get());

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

  1. @Override
  2. public void remove(String key) {
  3.   try {
  4.     db.remove(key.getBytes());
  5.   } catch (Exception e) {
  6.     LOG.error("Failed to remove " + key);
  7.   }
  8. }

代码示例来源：origin: weiboad/fiery

  1. public boolean del(String key) {
  2.   if (key.length() == 0) return false;
  3.   try {
  4.     db.remove(key.getBytes());
  5.     return true;
  6.   } catch (Exception e) {
  7.     e.printStackTrace();
  8.     log.error(e.getMessage());
  9.   }
  10.   return false;
  11. }

代码示例来源：origin: com.github.ltsopensource/lts-core

  1. @Override
  2. public void delete(String key) throws FailStoreException {
  3.   try {
  4.     db.remove(key.getBytes("UTF-8"));
  5.   } catch (Exception e) {
  6.     throw new FailStoreException(e);
  7.   }
  8. }

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

  1. @Override
  2. public void remove() {
  3.   if (cacheIndex == 0 || cacheIndex > cacheEntries.size()) {
  4.     throw new IllegalStateException("The remove operation must be called after an valid next operation.");
  5.   } 
  6.   RocksDBMapEntry lastEntry = cacheEntries.get(cacheIndex - 1);
  7.   lastEntry.remove();
  8. }

代码示例来源：origin: apsaltis/StreamingData-Book-Examples

  1. static void removeEvent(final String eventKey) throws Exception{
  2.   try {
  3.     final byte[] keyBytes = eventKey.getBytes(StandardCharsets.UTF_8);
  4.     byte[] value = transientStateDB.get(keyBytes);
  5.     if (value != null) {
  6.       transientStateDB.remove(keyBytes);
  7.     }
  8.   } catch (RocksDBException ex) {
  9.     //would want to log this occurring
  10.     throw new Exception(ex.getMessage());
  11.   }
  12. }

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

  1. @Override
  2. public void clear() {
  3.   try {
  4.     writeCurrentKeyWithGroupAndNamespace();
  5.     byte[] key = keySerializationStream.toByteArray();
  6.     backend.db.remove(columnFamily, writeOptions, key);
  7.   } catch (IOException|RocksDBException e) {
  8.     throw new RuntimeException("Error while removing entry from RocksDB", e);
  9.   }
  10. }

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

  1. @Override
  2. public Object get(String key) {
  3.   try {
  4.     byte[] data = db.get(key.getBytes());
  5.     if (data != null) {
  6.       try {
  7.         return deserialize(data);
  8.       } catch (Exception e) {
  9.         LOG.error("Failed to deserialize obj of " + key);
  10.         db.remove(key.getBytes());
  11.         return null;
  12.       }
  13.     }
  14.   } catch (Exception ignored) {
  15.   }
  16.   return null;
  17. }

代码示例来源：origin: org.locationtech.geogig/geogig-core

  1. @Override
  2. public V remove(Object key) {
  3.   putAll();
  4.   V value = get(key);
  5.   try {
  6.     ByteArrayOutputStream keyBytes = new ByteArrayOutputStream();
  7.     ObjectOutput keyOut = new ObjectOutputStream(keyBytes);
  8.     keyOut.writeObject(key);
  9.     keyOut.flush();
  10.     db.remove(keyBytes.toByteArray());
  11.   } catch (IOException | RocksDBException e) {
  12.     Throwables.propagate(e);
  13.   }
  14.   return value;
  15. }

代码示例来源：origin: apsaltis/StreamingData-Book-Examples

  1. static void moveToFailed(final String eventKey) {
  2.   try {
  3.     final byte[] keyBytes = eventKey.getBytes(StandardCharsets.UTF_8);
  4.     final byte[] eventBody = transientStateDB.get(keyBytes);
  5.     if(null != eventBody) {
  6.       failedStateDB.put(keyBytes, eventBody);
  7.       //now remove it from the transient
  8.       try {
  9.         transientStateDB.remove(keyBytes);
  10.       } catch (Exception ex) {
  11.         //we should at least log this....
  12.       }
  13.     }
  14.   } catch (Exception ex) {
  15.     //this should be logged and perhaps throw
  16.   }
  17. }

代码示例来源：origin: org.locationtech.geogig/geogig-rocksdb

  1. @Override
  2. public void removeBlob(String namespace, String path) {
  3.   try (RocksDBReference dbRef = db()) {
  4.     dbRef.db().remove(key(namespace, path));
  5.   } catch (RocksDBException e) {
  6.     throw Throwables.propagate(e);
  7.   }
  8. }

代码示例来源：origin: org.locationtech.geogig/geogig-rocksdb

  1. @Override
  2. public void delete(ObjectId objectId) {
  3.   checkNotNull(objectId, "argument objectId is null");
  4.   checkWritable();
  5.   byte[] key = objectId.getRawValue();
  6.   try (RocksDBReference dbRef = dbhandle.getReference()) {
  7.     dbRef.db().remove(key);
  8.   } catch (RocksDBException e) {
  9.     throw Throwables.propagate(e);
  10.   }
  11. }

代码示例来源：origin: org.jsimpledb/jsimpledb-kv-rocksdb

  1. @Override
  2. public void remove(byte[] key) {
  3.   key.getClass();
  4.   Preconditions.checkState(!this.closed, "closed");
  5.   this.cursorTracker.poll();
  6.   if (this.writeBatch != null) {
  7.     assert RocksDBUtil.isInitialized(this.writeBatch);
  8.     synchronized (this.writeBatch) {
  9.       this.writeBatch.remove(key);
  10.     }
  11.   } else {
  12.     assert RocksDBUtil.isInitialized(this.db);
  13.     try {
  14.       this.db.remove(key);
  15.     } catch (RocksDBException e) {
  16.       throw new RuntimeException("RocksDB error", e);
  17.     }
  18.   }
  19. }

代码示例来源：origin: org.locationtech.geogig/geogig-rocksdb

  1. @Override
  2.   public void removeBlobs(String namespace) {
  3.     byte[] namespacePrefix = (namespace + ".").getBytes();
  4.     try (RocksDBReference dbRef = db()) {
  5.       try (RocksIterator it = dbRef.db().newIterator()) {
  6.         it.seek(namespacePrefix);
  7.         while (it.isValid()) {
  8.           byte[] key = it.key();
  9.           for (int i = 0; i < namespacePrefix.length; i++) {
  10.             if (namespacePrefix[i] != key[i]) {
  11.               return;
  12.             }
  13.           }
  14.           try {
  15.             dbRef.db().remove(key);
  16.           } catch (RocksDBException e) {
  17.             Throwables.propagate(e);
  18.           }
  19.           it.next();
  20.         }
  21.       }
  22.     }
  23.   }
  24. }

内容来源于网络，如有侵权，请联系作者删除！

rocksdb

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com