Java 类org.apache.hadoop.hbase.io.hfile.slab.SlabCache 实例源码

项目：LCIndex-HBase-0.94.16 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：HIndex 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：IRIndex 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：RStore 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：PyroDB 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.byteDesc(onHeapSize)
      + " with an average block size of "
      + StringUtils.byteDesc(onHeapBlockSize));
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.byteDesc(offHeapSize)
      + "with an average block size of "
      + StringUtils.byteDesc(offHeapBlockSize));
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：c5 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：HBase-Research 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：hbase-0.94.8-qod 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：hbase-0.94.8-qod 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：DominoHBase 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}

项目：hindex 文件：DoubleBlockCache.java

/**
 * Default constructor. Specify maximum size and expected average block size
 * (approximation is fine).
 * <p>
 * All other factors will be calculated based on defaults specified in this
 * class.
 *
 * @param onHeapSize maximum size of the onHeapCache, in bytes.
 * @param offHeapSize maximum size of the offHeapCache, in bytes.
 * @param onHeapBlockSize average block size of the on heap cache.
 * @param offHeapBlockSize average block size for the off heap cache
 * @param conf configuration file. currently used only by the off heap cache.
 */
public DoubleBlockCache(long onHeapSize, long offHeapSize,
    long onHeapBlockSize, long offHeapBlockSize, Configuration conf) {

  LOG.info("Creating on-heap cache of size "
      + StringUtils.humanReadableInt(onHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(onHeapBlockSize) + " bytes.");
  onHeapCache = new LruBlockCache(onHeapSize, onHeapBlockSize, conf);

  LOG.info("Creating off-heap cache of size "
      + StringUtils.humanReadableInt(offHeapSize)
      + "bytes with an average block size of "
      + StringUtils.humanReadableInt(offHeapBlockSize) + " bytes.");
  offHeapCache = new SlabCache(offHeapSize, offHeapBlockSize);

  offHeapCache.addSlabByConf(conf);
  this.stats = new CacheStats();
}