import org.apache.mahout.math.map.OpenIntIntHashMap; //导入依赖的package包/类
/**
 * @param dictionaryFilePath
 * @param sigma
 * @return
 * @throws IOException
 */
public OpenIntIntHashMap getFListMap(String dictionaryFilePath, int sigma) throws IOException {
	  OpenIntIntHashMap fListMap = new OpenIntIntHashMap();
	  
	  int[] colsToLoad = new int[2];
	  colsToLoad[0] = Constants.DOC_FREQ;
      colsToLoad[1] = Constants.ITEM_ID;
      
      this.load(null, dictionaryFilePath, colsToLoad, sigma, -1);
	  
      int[] itemIdList = this.itemIds;
      for(int itemId : itemIdList) {
    	  int support = this.docFreqs[this.posOf(itemId)];
    	  fListMap.put(itemId, support);
      }
      return fListMap;
	  
  }
 

import org.apache.mahout.math.map.OpenIntIntHashMap; //导入依赖的package包/类
public static String createAndMeasureMahoutMutableIntIntHashMap(final Object[] data,
    int elementCount, int run, MemoryFootprintPreset preset) {
  org.apache.mahout.math.map.AbstractIntIntMap mutableYs = new OpenIntIntHashMap();

  for (Object o : data) {
    for (int i = 0; i < multimapValueSize; i++) {
      mutableYs.put((Integer) o, (Integer) i);
    }
  }

  return measureAndReport(mutableYs, "org.apache.mahout.math.map.OpenIntIntHashMap", DataType.MAP,
      Archetype.MUTABLE, false, elementCount, run, preset);
}
 

import org.apache.mahout.math.map.OpenIntIntHashMap; //导入依赖的package包/类
private void initCaches() {
  this.caches = new OpenIntIntHashMap[getProbes()];
  for (int ii = 0; ii < getProbes(); ii++) {
    caches[ii] = new OpenIntIntHashMap();
  }
}
 

import org.apache.mahout.math.map.OpenIntIntHashMap; //导入依赖的package包/类
protected OpenIntIntHashMap[] getCaches() {
  return caches;
}
 

import org.apache.mahout.math.map.OpenIntIntHashMap; //导入依赖的package包/类
public void load(Configuration conf, String fileName, int minSupport) throws IOException {
	
	BufferedReader br = null;
	if (conf == null) {
		@SuppressWarnings("resource")
		FileInputStream fstream = new FileInputStream(fileName);
		// Get the object of DataInputStream
		DataInputStream in = new DataInputStream(fstream);
		br = new BufferedReader(new InputStreamReader(in));
	} else {
		FileSystem fs = FileSystem.get(conf);
		FSDataInputStream dis = fs.open(new Path(fileName));
		br = new BufferedReader(new InputStreamReader(dis));
	}
	
	OpenIntIntHashMap parentMap = new OpenIntIntHashMap();
	
	String line = null;

	while ((line = br.readLine()) != null) {
		String[] splits = line.split("\t");
		int itemId = Integer.parseInt(splits[3]);
		int itemSupport = Integer.parseInt(splits[2]);
		
		int parentId = Integer.parseInt(splits[4]);
		
		parentMap.put(itemId, parentId);

		if (itemSupport >= minSupport) {
			items.add(PrimitiveUtils.combine(itemId, itemSupport));
		}
		itemIdToItemMap.put(itemId, splits[0]);
	}
	
	Collections.sort(items, new MyComparator());
	
	parentIds = new int[parentMap.size() + 1];
	IntArrayList keyList = parentMap.keys();
	for(int i = 0; i < keyList.size(); ++i) {
		int item = keyList.get(i); 
		parentIds[item] = parentMap.get(item);
	}
}
 

import org.apache.mahout.math.map.OpenIntIntHashMap; //导入依赖的package包/类
public void setFlistMap(OpenIntIntHashMap fListMap){
 this.fListMap = fListMap;
}