org.rocksdb.Options.dispose()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(2.7k)|赞(0)|评价(0)|浏览(110)

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

Options.dispose介绍

暂无

代码示例

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

@SuppressWarnings("unused")
public void initDb(List<Integer> list, Options dbOptions) throws Exception {
  LOG.info("Begin to init rocksDB of {}", rootDir);
  try {
    //List<ColumnFamilyHandle> columnFamilyHandleList = new ArrayList<ColumnFamilyHandle>();
    db = RocksDB.open(dbOptions, rootDir);
    LOG.info("Successfully init rocksDB of {}", rootDir);
  } finally {
    if (dbOptions != null) {
      dbOptions.dispose();
    }
  }
}

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

@Override
  public void destroy() throws FailStoreException {
    try {
      db.close();
      options.dispose();
    } catch (Exception e) {
      throw new FailStoreException(e);
    } finally {
      if (fileLock != null) {
        fileLock.release();
      }
      FileUtils.delete(dbPath);
    }
  }
}

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

@Override
  public void destroy() throws FailStoreException {
    try {
      db.close();
      options.dispose();
    } catch (Exception e) {
      throw new FailStoreException(e);
    } finally {
      if (fileLock != null) {
        fileLock.release();
      }
      FileUtils.delete(dbPath);
    }
  }
}

代码示例来源:origin: opencb/cellbase

private void closeIndex(RocksDB rdb, Options dbOption, String dbLocation) throws IOException {
  if (rdb != null) {
    rdb.close();
  }
  if (dbOption != null) {
    dbOption.dispose();
  }
  if (dbLocation != null && Files.exists(Paths.get(dbLocation))) {
    org.apache.commons.io.FileUtils.deleteDirectory(new File(dbLocation));
  }
}

代码示例来源:origin: opencb/cellbase

private void closeIndexes() throws IOException {
  for (int i = 0; i < dbIndexes.size(); i++) {
    dbIndexes.get(i).close();
    dbOptions.get(i).dispose();
  }
  if (populationFrequenciesFile != null) {
    org.apache.commons.io.FileUtils.deleteDirectory(new File(dbLocations.get(dbLocations.size() - 1)));
  }
}

代码示例来源:origin: org.opencb.biodata/biodata-tools

public void close() {
  if (rocksDB != null) {
    rocksDB.close();
  }
  if (options != null) {
    options.dispose();
  }
  connected = false;
}

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

@SuppressWarnings("unused")
public void initDb(List<Integer> list, Options dbOptions) throws Exception {
  LOG.info("Begin to init rocksDB of {}", rootDir);
  try {
    //List<ColumnFamilyHandle> columnFamilyHandleList = new ArrayList<ColumnFamilyHandle>();
    db = RocksDB.open(dbOptions, rootDir);
    LOG.info("Successfully init rocksDB of {}", rootDir);
  } finally {
    if (dbOptions != null) {
      dbOptions.dispose();
    }
  }
}

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

@Override
  public void destroy() throws FailStoreException {
    try {
      db.close();
      options.dispose();
    } catch (Exception e) {
      throw new FailStoreException(e);
    } finally {
      if (fileLock != null) {
        fileLock.release();
      }
      FileUtils.delete(dbPath);
    }
  }
}

相关文章

Options类方法