Java ReadOptions类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.rocksdb.ReadOptions类的典型用法代码示例。如果您正苦于以下问题：Java ReadOptions类的具体用法？Java ReadOptions怎么用？Java ReadOptions使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ReadOptions类属于org.rocksdb包，在下文中一共展示了ReadOptions类的12个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: writeKVStateMetaData

import org.rocksdb.ReadOptions; //导入依赖的package包/类
private void writeKVStateMetaData() throws IOException {

			List<RegisteredKeyedBackendStateMetaInfo.Snapshot<?, ?>> metaInfoSnapshots =
				new ArrayList<>(stateBackend.kvStateInformation.size());

			int kvStateId = 0;
			for (Map.Entry<String, Tuple2<ColumnFamilyHandle, RegisteredKeyedBackendStateMetaInfo<?, ?>>> column :
				stateBackend.kvStateInformation.entrySet()) {

				metaInfoSnapshots.add(column.getValue().f1.snapshot());

				//retrieve iterator for this k/v states
				readOptions = new ReadOptions();
				readOptions.setSnapshot(snapshot);

				kvStateIterators.add(
					new Tuple2<>(stateBackend.db.newIterator(column.getValue().f0, readOptions), kvStateId));

				++kvStateId;
			}

			KeyedBackendSerializationProxy<K> serializationProxy =
				new KeyedBackendSerializationProxy<>(
					stateBackend.getKeySerializer(),
					metaInfoSnapshots,
					!Objects.equals(UncompressedStreamCompressionDecorator.INSTANCE, stateBackend.keyGroupCompressionDecorator));

			serializationProxy.write(outputView);
		}

开发者ID:axbaretto，项目名称:flink，代码行数:30，代码来源:RocksDBKeyedStateBackend.java

示例2: setReadOptions

import org.rocksdb.ReadOptions; //导入依赖的package包/类
public RocksDbWrapper setReadOptions(ReadOptions readOptions) {
    if (this.readOptions != null) {
        RocksDbUtils.closeRocksObjects(this.readOptions);
    }
    this.readOptions = readOptions;
    myOwnReadOptions = false;
    return this;
}

开发者ID:DDTH，项目名称:ddth-queue，代码行数:9，代码来源:RocksDbWrapper.java

示例3: get

import org.rocksdb.ReadOptions; //导入依赖的package包/类
/**
 * Gets a value from a column family, specifying read options.
 * 
 * @param cfName
 * @param readOptions
 * @param key
 * @return
 * @throws RocksDbException
 */
public byte[] get(String cfName, ReadOptions readOptions, String key) throws RocksDbException {
    if (cfName == null) {
        cfName = DEFAULT_COLUMN_FAMILY;
    }
    ColumnFamilyHandle cfh = columnFamilyHandles.get(cfName);
    if (cfh == null) {
        throw new RocksDbException.ColumnFamilyNotExists(cfName);
    }
    return get(cfh, readOptions != null ? readOptions : this.readOptions,
            key.getBytes(RocksDbUtils.UTF8));
}

开发者ID:DDTH，项目名称:ddth-queue，代码行数:21，代码来源:RocksDbWrapper.java

示例4: setReadOptions

import org.rocksdb.ReadOptions; //导入依赖的package包/类
public RocksDbWrapper setReadOptions(ReadOptions readOptions) {
    if (this.readOptions != null && myOwnReadOptions) {
        RocksDbUtils.closeRocksObjects(this.readOptions);
    }
    this.readOptions = readOptions;
    myOwnReadOptions = false;
    return this;
}

开发者ID:DDTH，项目名称:ddth-commons，代码行数:9，代码来源:RocksDbWrapper.java

示例5: get

import org.rocksdb.ReadOptions; //导入依赖的package包/类
/**
 * Gets a value from a column family, specifying read options.
 * 
 * @param cfName
 * @param readOptions
 * @param key
 * @return
 * @throws RocksDbException
 */
public byte[] get(String cfName, ReadOptions readOptions, String key) throws RocksDbException {
    if (cfName == null) {
        cfName = DEFAULT_COLUMN_FAMILY;
    }
    ColumnFamilyHandle cfh = columnFamilyHandles.get(cfName);
    if (cfh == null) {
        throw new RocksDbException.ColumnFamilyNotExists(cfName);
    }
    return get(cfh, readOptions, key.getBytes(RocksDbUtils.UTF8));
}

开发者ID:DDTH，项目名称:ddth-commons，代码行数:20，代码来源:RocksDbWrapper.java

示例6: FeatureStoreRocksDb

import org.rocksdb.ReadOptions; //导入依赖的package包/类
FeatureStoreRocksDb(MetricsContext metricsContext, File dbPath) {

    MetricRegistry metrics = metricsContext.metrics();
    String context = metricsContext.context();

    putTimer = metrics.timer(MetricRegistry.name(
        context + "." + METRICS_PATH, "putTimer"));
    putMeter = metrics.meter(MetricRegistry.name(
        context + "." + METRICS_PATH, "putMeter"));
    this.loadAllTimer = metrics.timer(MetricRegistry.name(
        context + "." + METRICS_PATH, "loadAllTimer"));
    this.loadAllMeter = metrics.meter(MetricRegistry.name(
        context + "." + METRICS_PATH, "loadAllMeter"));

    this.findAllTimer = metrics.timer(MetricRegistry.name(
        context + "." + METRICS_PATH, "findAllTimer"));
    this.findAllMeter = metrics.meter(MetricRegistry.name(
        context + "." + METRICS_PATH, "findAllMeter"));

    BlockBasedTableConfig tableConfig = new BlockBasedTableConfig();
    tableConfig.setBlockCacheSize(BLOCK_CACHE_SIZE);
    tableConfig.setBlockSize(BLOCK_SIZE);

    options = new Options();
    options.setTableFormatConfig(tableConfig);
    options.setWriteBufferSize(WRITE_BUFFER_SIZE);
    options.setCompressionType(COMPRESSION_TYPE);
    options.setCompactionStyle(COMPACTION_STYLE);
    options.setMaxWriteBufferNumber(MAX_WRITE_BUFFER_NUMBER);
    options.setCreateIfMissing(CREATE_IF_MISSING);
    options.setErrorIfExists(ERROR_IF_EXISTS);
    writeOptions = new WriteOptions();
    writeOptions.setDisableWAL(DISABLE_WAL);
    writeOptions.setSync(true);
    readOptions = new ReadOptions();
    readOptions.setVerifyChecksums(true);
    readOptions.setFillCache(true);
    flushOptions = new FlushOptions();
    flushOptions.setWaitForFlush(WAIT_FOR_FLUSH);

    final File parent = new File("/tmp", "outland");
    rocksDir = new File(dbPath, "feature-store");
    //noinspection ResultOfMethodCallIgnored
    rocksDir.getParentFile().mkdirs();
    rocks = initializeRocksDb(); // todo: move this out?
  }

开发者ID:dehora，项目名称:outland，代码行数:47，代码来源:FeatureStoreRocksDb.java

示例7: getReadOptions

import org.rocksdb.ReadOptions; //导入依赖的package包/类
public ReadOptions getReadOptions() {
    return this.readOptions;
}

开发者ID:DDTH，项目名称:ddth-queue，代码行数:4，代码来源:RocksDbWrapper.java

示例8: openReadOnly

import org.rocksdb.ReadOptions; //导入依赖的package包/类
/**
 * Opens a RocksDB with specified options in read-only mode.
 * 
 * @param directory
 *            existing RocksDB data directory
 * @param dbOptions
 * @param readOptions
 * @return
 * @throws RocksDBException
 */
public static RocksDbWrapper openReadOnly(File directory, DBOptions dbOptions,
        ReadOptions readOptions) throws RocksDBException {
    RocksDbWrapper rocksDbWrapper = new RocksDbWrapper(directory, true);
    rocksDbWrapper.setDbOptions(dbOptions).setReadOptions(readOptions);
    rocksDbWrapper.init();
    return rocksDbWrapper;
}

开发者ID:DDTH，项目名称:ddth-queue，代码行数:18，代码来源:RocksDbWrapper.java

示例9: openReadWrite

import org.rocksdb.ReadOptions; //导入依赖的package包/类
/**
 * Opens a RocksDB with specified options in read/write mode.
 * 
 * @param directory
 *            directory to store RocksDB data
 * @param dbOptions
 * @param readOptions
 * @param writeOptions
 * @param columnFamilies
 *            list of column families to store key/value (the column family
 *            "default" will be automatically added)
 * @return
 * @throws RocksDBException
 */
public static RocksDbWrapper openReadWrite(File directory, DBOptions dbOptions,
        ReadOptions readOptions, WriteOptions writeOptions, String[] columnFamilies)
        throws RocksDBException {
    RocksDbWrapper rocksDbWrapper = new RocksDbWrapper(directory, false);
    rocksDbWrapper.setDbOptions(dbOptions).setReadOptions(readOptions)
            .setWriteOptions(writeOptions);
    rocksDbWrapper.setColumnFamilies(RocksDbUtils.buildColumnFamilyDescriptors(columnFamilies));
    rocksDbWrapper.init();
    return rocksDbWrapper;
}

开发者ID:DDTH，项目名称:ddth-queue，代码行数:25，代码来源:RocksDbWrapper.java

示例10: openReadOnly

import org.rocksdb.ReadOptions; //导入依赖的package包/类
/**
 * Open a {@link RocksDB} with specified options in read-only mode.
 * 
 * @param directory
 *            existing {@link RocksDB} data directory
 * @param dbOptions
 * @param readOptions
 * @return
 * @throws RocksDBException
 * @throws IOException
 */
public static RocksDbWrapper openReadOnly(File directory, DBOptions dbOptions,
        ReadOptions readOptions) throws RocksDbException, IOException {
    RocksDbWrapper rocksDbWrapper = new RocksDbWrapper(directory, true);
    rocksDbWrapper.setDbOptions(dbOptions).setReadOptions(readOptions);
    rocksDbWrapper.init();
    return rocksDbWrapper;
}

开发者ID:DDTH，项目名称:ddth-commons，代码行数:19，代码来源:RocksDbWrapper.java

示例11: openReadWrite

import org.rocksdb.ReadOptions; //导入依赖的package包/类
/**
 * Open a {@link RocksDB} with specified options in read/write mode.
 * 
 * @param directory
 *            directory to store {@link RocksDB} data
 * @param dbOptions
 * @param readOptions
 * @param writeOptions
 * @param columnFamilies
 *            list of column families to store key/value (the column family
 *            "default" will be automatically added)
 * @return
 * @throws RocksDbException
 * @throws IOException
 */
public static RocksDbWrapper openReadWrite(File directory, DBOptions dbOptions,
        ReadOptions readOptions, WriteOptions writeOptions, String... columnFamilies)
        throws RocksDbException, IOException {
    RocksDbWrapper rocksDbWrapper = new RocksDbWrapper(directory, false);
    rocksDbWrapper.setDbOptions(dbOptions).setReadOptions(readOptions)
            .setWriteOptions(writeOptions);
    rocksDbWrapper.setColumnFamilies(RocksDbUtils.buildColumnFamilyDescriptors(columnFamilies));
    rocksDbWrapper.init();
    return rocksDbWrapper;
}

开发者ID:DDTH，项目名称:ddth-commons，代码行数:26，代码来源:RocksDbWrapper.java

示例12: buildReadOptions

import org.rocksdb.ReadOptions; //导入依赖的package包/类
/**
 * Builds default RocskDb ReadOptions.
 * 
 * @return
 */
public static ReadOptions buildReadOptions() {
    return buildReadOptions(true);
}

开发者ID:DDTH，项目名称:ddth-queue，代码行数:9，代码来源:RocksDbUtils.java

注：本文中的org.rocksdb.ReadOptions类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java UserInfo类代码示例发布时间：2022-05-22

Java RuleService类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19165|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9981|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8320|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8690|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8634|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9650|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8617|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7994|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8648|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7531|2022-11-06

客服电话

电子邮件

Java ReadOptions类代码示例

示例1: writeKVStateMetaData

示例2: setReadOptions

示例3: get

示例4: setReadOptions

示例5: get

示例6: FeatureStoreRocksDb

示例7: getReadOptions

示例8: openReadOnly

示例9: openReadWrite

示例10: openReadOnly

示例11: openReadWrite

示例12: buildReadOptions

请发表评论

全部评论

上一篇：

下一篇：

kojino/Harvard-Robust-Machine-Learning:

cescoffier/puppet-nexus: A Puppet Module

文的笔顺,诠释文的笔画,解读文的部首

Cassolotl/sentient.cloud · GitHub

CVE-2022-31836

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053