Java StripeCompactionPolicy类的典型用法和代码示例

本文整理汇总了Java中org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy类的典型用法代码示例。如果您正苦于以下问题：Java StripeCompactionPolicy类的具体用法？Java StripeCompactionPolicy怎么用？Java StripeCompactionPolicy使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

StripeCompactionPolicy类属于org.apache.hadoop.hbase.regionserver.compactions包，在下文中一共展示了StripeCompactionPolicy类的8个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: debugDumpState

import org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy; //导入依赖的package包/类
private void debugDumpState(String string) {
  if (!LOG.isDebugEnabled()) return;
  StringBuilder sb = new StringBuilder();
  sb.append("\n" + string + "; current stripe state is as such:");
  sb.append("\n level 0 with ")
      .append(state.level0Files.size())
      .append(
        " files: "
            + TraditionalBinaryPrefix.long2String(
              StripeCompactionPolicy.getTotalFileSize(state.level0Files), "", 1) + ";");
  for (int i = 0; i < state.stripeFiles.size(); ++i) {
    String endRow = (i == state.stripeEndRows.length)
        ? "(end)" : "[" + Bytes.toString(state.stripeEndRows[i]) + "]";
    sb.append("\n stripe ending in ")
        .append(endRow)
        .append(" with ")
        .append(state.stripeFiles.get(i).size())
        .append(
          " files: "
              + TraditionalBinaryPrefix.long2String(
                StripeCompactionPolicy.getTotalFileSize(state.stripeFiles.get(i)), "", 1) + ";");
  }
  sb.append("\n").append(state.stripeFiles.size()).append(" stripes total.");
  sb.append("\n").append(getStorefileCount()).append(" files total.");
  LOG.debug(sb.toString());
}

开发者ID:fengchen8086，
项目名称:ditb，
代码行数:27，
代码来源:StripeStoreFileManager.java

示例2: debugDumpState

import org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy; //导入依赖的package包/类
private void debugDumpState(String string) {
  if (!LOG.isDebugEnabled()) return;
  StringBuilder sb = new StringBuilder();
  sb.append("\n" + string + "; current stripe state is as such:");
  sb.append("\n level 0 with ").append(state.level0Files.size())
      .append(
        " files: "
            + StringUtils.humanReadableInt(StripeCompactionPolicy
                .getTotalFileSize(state.level0Files)) + ";");
  for (int i = 0; i < state.stripeFiles.size(); ++i) {
    String endRow = (i == state.stripeEndRows.length)
        ? "(end)" : "[" + Bytes.toString(state.stripeEndRows[i]) + "]";
    sb.append("\n stripe ending in ").append(endRow).append(" with ")
        .append(state.stripeFiles.get(i).size())
        .append(
          " files: "
              + StringUtils.humanReadableInt(StripeCompactionPolicy
                  .getTotalFileSize(state.stripeFiles.get(i))) + ";");
  }
  sb.append("\n").append(state.stripeFiles.size()).append(" stripes total.");
  sb.append("\n").append(getStorefileCount()).append(" files total.");
  LOG.debug(sb.toString());
}

开发者ID:grokcoder，
项目名称:pbase，
代码行数:24，
代码来源:StripeStoreFileManager.java

示例3: createComponents

import org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy; //导入依赖的package包/类
@Override
protected void createComponents(
    Configuration conf, Store store, KVComparator comparator) throws IOException {
  this.config = new StripeStoreConfig(conf, store);
  this.compactionPolicy = new StripeCompactionPolicy(conf, store, config);
  this.storeFileManager = new StripeStoreFileManager(comparator, conf, this.config);
  this.storeFlusher = new StripeStoreFlusher(
    conf, store, this.compactionPolicy, this.storeFileManager);
  this.compactor = new StripeCompactor(conf, store);
}

开发者ID:fengchen8086，
项目名称:ditb，
代码行数:11，
代码来源:StripeStoreEngine.java

示例4: testCreateBasedOnConfig

import org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy; //导入依赖的package包/类
@Test
public void testCreateBasedOnConfig() throws Exception {
  Configuration conf = HBaseConfiguration.create();
  conf.set(StoreEngine.STORE_ENGINE_CLASS_KEY, TestStoreEngine.class.getName());
  StripeStoreEngine se = createEngine(conf);
  assertTrue(se.getCompactionPolicy() instanceof StripeCompactionPolicy);
}

开发者ID:fengchen8086，
项目名称:ditb，
代码行数:8，
代码来源:TestStripeStoreEngine.java

示例5: createComponents

import org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy; //导入依赖的package包/类
@Override
protected void createComponents(
    Configuration conf, HStore store, CellComparator comparator) throws IOException {
  this.config = new StripeStoreConfig(conf, store);
  this.compactionPolicy = new StripeCompactionPolicy(conf, store, config);
  this.storeFileManager = new StripeStoreFileManager(comparator, conf, this.config);
  this.storeFlusher = new StripeStoreFlusher(
    conf, store, this.compactionPolicy, this.storeFileManager);
  this.compactor = new StripeCompactor(conf, store);
}

开发者ID:apache，
项目名称:hbase，
代码行数:11，
代码来源:StripeStoreEngine.java

示例6: StripeStoreFlusher

import org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy; //导入依赖的package包/类
public StripeStoreFlusher(Configuration conf, Store store, StripeCompactionPolicy policy,
    StripeStoreFileManager stripes) {
  super(conf, store);
  this.policy = policy;
  this.stripes = stripes;
}

开发者ID:fengchen8086，
项目名称:ditb，
代码行数:7，
代码来源:StripeStoreFlusher.java

示例7: StripeStoreFlusher

import org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy; //导入依赖的package包/类
public StripeStoreFlusher(Configuration conf, Store store,
    StripeCompactionPolicy policy, StripeStoreFileManager stripes) {
  super(conf, store);
  this.policy = policy;
  this.stripes = stripes;
}

开发者ID:grokcoder，
项目名称:pbase，
代码行数:7，
代码来源:StripeStoreFlusher.java

示例8: StripeStoreFlusher

import org.apache.hadoop.hbase.regionserver.compactions.StripeCompactionPolicy; //导入依赖的package包/类
public StripeStoreFlusher(Configuration conf, HStore store,
    StripeCompactionPolicy policy, StripeStoreFileManager stripes) {
  super(conf, store);
  this.policy = policy;
  this.stripes = stripes;
}

开发者ID:apache，
项目名称:hbase，
代码行数:7，
代码来源:StripeStoreFlusher.java