本文整理了Java中com.hazelcast.config.Config.addRingBufferConfig()
方法的一些代码示例,展示了Config.addRingBufferConfig()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Config.addRingBufferConfig()
方法的具体详情如下:
包路径:com.hazelcast.config.Config
类名称:Config
方法名:addRingBufferConfig
[英]Adds the ringbuffer configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtained in the future.
[中]添加ringbuffer配置。配置保存在配置名称下,该名称可能是将来获取配置的模式。
代码示例来源:origin: hazelcast/hazelcast-code-samples
public static void main(String[] args) throws Exception {
Config config = new Config()
.addRingBufferConfig(getConfig("object-ringbuffer", OBJECT, TheRingbufferObjectStore.class))
.addRingBufferConfig(getConfig("binary-ringbuffer", BINARY, TheRingbufferBinaryStore.class));
HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);
hz.getRingbuffer("object-ringbuffer").add(new Item());
hz.getRingbuffer("binary-ringbuffer").add(new Item());
System.exit(0);
}
代码示例来源:origin: hazelcast/hazelcast-code-samples
public static void main(String[] args) {
// for a custom merge policy we have to provide the FQCN, not just the simple classname
MergePolicyConfig mergePolicyConfig = new MergePolicyConfig()
.setPolicy(RingbufferMergeIntegerValuesMergePolicy.class.getName());
RingbufferConfig ringbufferConfig = new RingbufferConfig()
.setName(RINGBUFFER_NAME)
.setMergePolicyConfig(mergePolicyConfig);
Config config = new Config()
//.setProperty("hazelcast.logging.type", "none")
.addRingBufferConfig(ringbufferConfig);
HazelcastInstanceFactory.newHazelcastInstance(config);
Hazelcast.shutdownAll();
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
config.addRingBufferConfig(rbConfig);
代码示例来源:origin: com.hazelcast/hazelcast-all
config.addRingBufferConfig(rbConfig);
代码示例来源:origin: com.obsidiandynamics.meteor/meteor-core
static Ringbuffer<byte[]> getRingbuffer(HazelcastInstance instance, StreamConfig streamConfig) {
final String streamFQName = Namespace.METEOR_STREAM.qualify(streamConfig.getName());
final RingbufferConfig ringbufferConfig = new RingbufferConfig(streamFQName)
.setBackupCount(streamConfig.getSyncReplicas())
.setAsyncBackupCount(streamConfig.getAsyncReplicas())
.setCapacity(streamConfig.getHeapCapacity())
.setRingbufferStoreConfig(streamConfig.getRingbufferStoreConfig());
instance.getConfig().addRingBufferConfig(ringbufferConfig);
return instance.getRingbuffer(streamFQName);
}
内容来源于网络,如有侵权,请联系作者删除!