Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-18 16:12:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

enable consistent hashing and optimizations + daemonize memcached IO thread

Browse Source
This commit is contained in:
xvrl 2012-12-04 11:18:51 -08:00
parent 98fbcfd7c2
commit 51a7adf4fe
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
client/src/main/java/com/metamx/druid/client/cache/MemcachedCacheBroker.java vendored
View File

@ -22,6 +22,7 @@ package com.metamx.druid.client.cache;
import net.iharder.base64.Base64; import net.iharder.base64.Base64;
import net.spy.memcached.AddrUtil; import net.spy.memcached.AddrUtil;
import net.spy.memcached.ConnectionFactoryBuilder; import net.spy.memcached.ConnectionFactoryBuilder;
import net.spy.memcached.DefaultHashAlgorithm;
import net.spy.memcached.MemcachedClient; import net.spy.memcached.MemcachedClient;
import net.spy.memcached.MemcachedClientIF; import net.spy.memcached.MemcachedClientIF;
@ -39,7 +40,12 @@ public class MemcachedCacheBroker implements CacheBroker
try { try {
return new MemcachedCacheBroker( return new MemcachedCacheBroker(
new MemcachedClient( new MemcachedClient(
new ConnectionFactoryBuilder().setProtocol(ConnectionFactoryBuilder.Protocol.BINARY).build(), new ConnectionFactoryBuilder().setProtocol(ConnectionFactoryBuilder.Protocol.BINARY)
.setHashAlg(DefaultHashAlgorithm.FNV1A_64_HASH)
.setLocatorType(ConnectionFactoryBuilder.Locator.CONSISTENT)
.setDaemon(true)
.setShouldOptimize(true)
.build(),
AddrUtil.getAddresses(config.getHosts()) AddrUtil.getAddresses(config.getHosts())
), ),
config.getTimeout(), config.getTimeout(),