本文整理了Java中org.rocksdb.Options.dispose()
方法的一些代码示例,展示了Options.dispose()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Options.dispose()
方法的具体详情如下:
包路径:org.rocksdb.Options
类名称: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);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!