本文整理了Java中org.rocksdb.RocksDB.close
方法的一些代码示例,展示了RocksDB.close
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RocksDB.close
方法的具体详情如下:
包路径:org.rocksdb.RocksDB
类名称:RocksDB
方法名:close
暂无
代码示例来源:origin: alibaba/jstorm
@Override
public void cleanup() {
LOG.info("Begin to close rocketDb of {}", rootDir);
if (db != null) {
db.close();
}
LOG.info("Successfully closed rocketDb of {}", rootDir);
}
代码示例来源:origin: ltsopensource/light-task-scheduler
@Override
public void close() throws FailStoreException {
try {
if (db != null) {
db.close();
}
} catch (Exception e) {
throw new FailStoreException(e);
}
}
代码示例来源:origin: voldemort/voldemort
@Override
public void close() throws VoldemortException {
storeHandle.dispose();
rocksDB.close();
}
代码示例来源:origin: apache/kylin
@Override
public void close() throws IOException {
options.close();
if (rocksDB != null) {
rocksDB.close();
}
}
}
代码示例来源:origin: ltsopensource/light-task-scheduler
@Override
public void close() throws FailStoreException {
try {
if (db != null) {
db.close();
}
} catch (Exception e) {
throw new FailStoreException(e);
}
}
代码示例来源:origin: ethereum/ethereumj
@Override
public void close() {
resetDbLock.writeLock().lock();
try {
if (!isAlive()) return;
logger.debug("Close db: {}", name);
db.close();
readOpts.close();
alive = false;
} catch (Exception e) {
logger.error("Error closing db '{}'", name, e);
} finally {
resetDbLock.writeLock().unlock();
}
}
代码示例来源:origin: Alluxio/alluxio
mBlockMetaColumn.close();
mBlockLocationsColumn.close();
mDb.close();
} catch (Throwable t) {
LOG.error("Failed to close previous rocks database", t);
代码示例来源: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: Alluxio/alluxio
mInodesColumn.close();
mEdgesColumn.close();
mDb.close();
} catch (Throwable t) {
LOG.error("Failed to close previous rocks database at {}", mDbPath, t);
代码示例来源:origin: brianfrankcooper/YCSB
@Override
public void cleanup() throws DBException {
super.cleanup();
synchronized (RocksDBClient.class) {
try {
if (references == 1) {
for (final ColumnFamily cf : COLUMN_FAMILIES.values()) {
cf.getHandle().close();
}
rocksDb.close();
rocksDb = null;
dbOptions.close();
dbOptions = null;
for (final ColumnFamily cf : COLUMN_FAMILIES.values()) {
cf.getOptions().close();
}
saveColumnFamilyNames();
COLUMN_FAMILIES.clear();
rocksDbDir = null;
}
} catch (final IOException e) {
throw new DBException(e);
} finally {
references--;
}
}
}
代码示例来源:origin: alibaba/jstorm
db.close();
代码示例来源:origin: hugegraph/hugegraph
@Override
protected synchronized void doClose() {
this.checkValid();
for (ColumnFamilyHandle cf : this.cfs.values()) {
cf.close();
}
this.cfs.clear();
this.rocksdb.close();
}
代码示例来源:origin: weiboad/fiery
public void close() {
if (db != null) db.close();
//options.dispose();
}
}
代码示例来源:origin: locationtech/geowave
public void close() {
synchronized (this) {
if (writeDb != null) {
writeDb.close();
writeDb = null;
}
if (readDb != null) {
readDb.close();
}
}
}
代码示例来源:origin: apache/samza
public void stop() {
log.debug("closing the db");
if (db != null) {
db.close();
}
log.info("db is closed.");
}
代码示例来源:origin: dremio/dremio-oss
@Override
protected void after() {
db.close();
}
}
代码示例来源:origin: locationtech/geogig
public void close() {
if (db != null) {
writeOptions.close();
writeOptions = null;
db.close();
db = null;
deleteDB();
dbDir = null;
}
}
代码示例来源:origin: apache/samza
@AfterClass
static public void tearDownRocksDb() {
if (db != null) {
db.close();
}
if (Files.exists(dirPath)) {
removeRecursiveDirectory(dirPath);
}
}
代码示例来源:origin: org.apache.bookkeeper/bookkeeper-server
@Override
public void close() throws IOException {
db.close();
optionSync.close();
optionDontSync.close();
optionCache.close();
optionDontCache.close();
emptyBatch.close();
}
内容来源于网络,如有侵权,请联系作者删除!