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

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

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

RocksDB.close介绍

暂无

代码示例

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

  1. @Override
  2. public void cleanup() {
  3. LOG.info("Begin to close rocketDb of {}", rootDir);
  4. if (db != null) {
  5. db.close();
  6. }
  7. LOG.info("Successfully closed rocketDb of {}", rootDir);
  8. }

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

  1. @Override
  2. public void close() throws FailStoreException {
  3. try {
  4. if (db != null) {
  5. db.close();
  6. }
  7. } catch (Exception e) {
  8. throw new FailStoreException(e);
  9. }
  10. }

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

  1. @Override
  2. public void close() throws VoldemortException {
  3. storeHandle.dispose();
  4. rocksDB.close();
  5. }

代码示例来源:origin: apache/kylin

  1. @Override
  2. public void close() throws IOException {
  3. options.close();
  4. if (rocksDB != null) {
  5. rocksDB.close();
  6. }
  7. }
  8. }

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

  1. @Override
  2. public void close() throws FailStoreException {
  3. try {
  4. if (db != null) {
  5. db.close();
  6. }
  7. } catch (Exception e) {
  8. throw new FailStoreException(e);
  9. }
  10. }

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

  1. @Override
  2. public void close() {
  3. resetDbLock.writeLock().lock();
  4. try {
  5. if (!isAlive()) return;
  6. logger.debug("Close db: {}", name);
  7. db.close();
  8. readOpts.close();
  9. alive = false;
  10. } catch (Exception e) {
  11. logger.error("Error closing db '{}'", name, e);
  12. } finally {
  13. resetDbLock.writeLock().unlock();
  14. }
  15. }

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

  1. mBlockMetaColumn.close();
  2. mBlockLocationsColumn.close();
  3. mDb.close();
  4. } catch (Throwable t) {
  5. LOG.error("Failed to close previous rocks database", t);

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

  1. @Override
  2. public void destroy() throws FailStoreException {
  3. try {
  4. db.close();
  5. options.dispose();
  6. } catch (Exception e) {
  7. throw new FailStoreException(e);
  8. } finally {
  9. if (fileLock != null) {
  10. fileLock.release();
  11. }
  12. FileUtils.delete(dbPath);
  13. }
  14. }
  15. }

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

  1. @Override
  2. public void destroy() throws FailStoreException {
  3. try {
  4. db.close();
  5. options.dispose();
  6. } catch (Exception e) {
  7. throw new FailStoreException(e);
  8. } finally {
  9. if (fileLock != null) {
  10. fileLock.release();
  11. }
  12. FileUtils.delete(dbPath);
  13. }
  14. }
  15. }

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

  1. mInodesColumn.close();
  2. mEdgesColumn.close();
  3. mDb.close();
  4. } catch (Throwable t) {
  5. LOG.error("Failed to close previous rocks database at {}", mDbPath, t);

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

  1. @Override
  2. public void cleanup() throws DBException {
  3. super.cleanup();
  4. synchronized (RocksDBClient.class) {
  5. try {
  6. if (references == 1) {
  7. for (final ColumnFamily cf : COLUMN_FAMILIES.values()) {
  8. cf.getHandle().close();
  9. }
  10. rocksDb.close();
  11. rocksDb = null;
  12. dbOptions.close();
  13. dbOptions = null;
  14. for (final ColumnFamily cf : COLUMN_FAMILIES.values()) {
  15. cf.getOptions().close();
  16. }
  17. saveColumnFamilyNames();
  18. COLUMN_FAMILIES.clear();
  19. rocksDbDir = null;
  20. }
  21. } catch (final IOException e) {
  22. throw new DBException(e);
  23. } finally {
  24. references--;
  25. }
  26. }
  27. }

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

  1. db.close();

代码示例来源:origin: hugegraph/hugegraph

  1. @Override
  2. protected synchronized void doClose() {
  3. this.checkValid();
  4. for (ColumnFamilyHandle cf : this.cfs.values()) {
  5. cf.close();
  6. }
  7. this.cfs.clear();
  8. this.rocksdb.close();
  9. }

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

  1. public void close() {
  2. if (db != null) db.close();
  3. //options.dispose();
  4. }
  5. }

代码示例来源:origin: locationtech/geowave

  1. public void close() {
  2. synchronized (this) {
  3. if (writeDb != null) {
  4. writeDb.close();
  5. writeDb = null;
  6. }
  7. if (readDb != null) {
  8. readDb.close();
  9. }
  10. }
  11. }

代码示例来源:origin: apache/samza

  1. public void stop() {
  2. log.debug("closing the db");
  3. if (db != null) {
  4. db.close();
  5. }
  6. log.info("db is closed.");
  7. }

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

  1. @Override
  2. protected void after() {
  3. db.close();
  4. }
  5. }

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

  1. public void close() {
  2. if (db != null) {
  3. writeOptions.close();
  4. writeOptions = null;
  5. db.close();
  6. db = null;
  7. deleteDB();
  8. dbDir = null;
  9. }
  10. }

代码示例来源:origin: apache/samza

  1. @AfterClass
  2. static public void tearDownRocksDb() {
  3. if (db != null) {
  4. db.close();
  5. }
  6. if (Files.exists(dirPath)) {
  7. removeRecursiveDirectory(dirPath);
  8. }
  9. }

代码示例来源:origin: org.apache.bookkeeper/bookkeeper-server

  1. @Override
  2. public void close() throws IOException {
  3. db.close();
  4. optionSync.close();
  5. optionDontSync.close();
  6. optionCache.close();
  7. optionDontCache.close();
  8. emptyBatch.close();
  9. }

相关文章