public void merge(Collector<T> collector){
    	if(null != collector){
    		ConcurrentMap<String, Set<T>> map = collector.getDataSetMap();
    		if(null == map || map.isEmpty()){
    			return;
    		}
    		Set<String> keys = map.keySet();
    		for(String key : keys){
    			Set<T> s1 = this.dataSetMap.get(key);
    			if(null != s1){
    				s1.addAll(map.get(key));
    			} else {
    				Set<T> s2 = map.get(key);
    				if(null != s2 && !s2.isEmpty()){
    					this.dataSetMap.put(key, s2);
    				}
    			}
    		}
    	}
    }