diff --git a/src/main/java/io/mycat/route/function/PartitionByMurmurHash.java b/src/main/java/io/mycat/route/function/PartitionByMurmurHash.java index 12d77da8a..6eb28f8ae 100644 --- a/src/main/java/io/mycat/route/function/PartitionByMurmurHash.java +++ b/src/main/java/io/mycat/route/function/PartitionByMurmurHash.java @@ -56,8 +56,6 @@ public class PartitionByMurmurHash extends AbstractPartitionAlgorithm implements private int seed; private int count; private int virtualBucketTimes=DEFAULT_VIRTUAL_BUCKET_TIMES; - private Map weightMap=new HashMap<>(); -// private String bucketMapPath; private HashFunction hash; @@ -66,18 +64,7 @@ public class PartitionByMurmurHash extends AbstractPartitionAlgorithm implements public void init() { try{ bucketMap=new TreeMap<>(); -// boolean serializableBucketMap=bucketMapPath!=null && bucketMapPath.length()>0; -// if(serializableBucketMap){ -// File bucketMapFile=new File(bucketMapPath); -// if(bucketMapFile.exists() && bucketMapFile.length()>0){ -// loadBucketMapFile(); -// return; -// } -// } generateBucketMap(); -// if(serializableBucketMap){ -// storeBucketMap(); -// } }catch(Exception e){ throw new MurmurHashException(e); } @@ -87,43 +74,10 @@ private void generateBucketMap(){ hash=Hashing.murmur3_32(seed);//计算一致性哈希的对象 for(int i=0;i0?weight:1); - } - } - } -// /** -// * 保存一致性hash的虚拟节点文件路径。 -// * 如果这个文件不存在或是空文件就按照指定的count, weightMapFile等构造新的MurmurHash数据结构并保存到这个路径的文件里。 -// * 如果这个文件已存在且不是空文件就加载这个文件里的内容作为MurmurHash数据结构,此时其它参数都忽略。 -// * 除第一次以外在之后增加节点时可以直接修改这个文件,不过不推荐这么做。如果节点数量变化了,推荐删除这个文件。 -// * 可以不指定这个路径,不指定路径时不会保存murmur hash -// * @param bucketMapPath -// */ -// public void setBucketMapPath(String bucketMapPath){ -// this.bucketMapPath=bucketMapPath; -// } @Override public Integer calculate(String columnValue) { SortedMap tail = bucketMap.tailMap(hash.hashUnencodedChars(columnValue).asInt());