org.apache.hadoop.hbase.client.Admin.compactRegion()方法的使用及代码示例

x33g5p2x  于2022-01-15 转载在 其他  
字(3.9k)|赞(0)|评价(0)|浏览(118)

本文整理了Java中org.apache.hadoop.hbase.client.Admin.compactRegion()方法的一些代码示例,展示了Admin.compactRegion()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Admin.compactRegion()方法的具体详情如下:
包路径:org.apache.hadoop.hbase.client.Admin
类名称:Admin
方法名:compactRegion

Admin.compactRegion介绍

[英]Compact an individual region. Asynchronous operation.
[中]压缩单个区域。异步操作。

代码示例

代码示例来源:origin: apache/hbase

@Override
public void compact(ByteBuffer tableNameOrRegionName) throws IOError {
 try {
  try {
   getAdmin().compactRegion(getBytes(tableNameOrRegionName));
  } catch (IllegalArgumentException e) {
   // Invalid region, try table
   getAdmin().compact(TableName.valueOf(getBytes(tableNameOrRegionName)));
  }
 } catch (IOException e) {
  LOG.warn(e.getMessage(), e);
  throw getIOError(e);
 }
}

代码示例来源:origin: apache/hbase

@Override
public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError {
 try {
  try {
   getAdmin().compactRegion(getBytes(tableNameOrRegionName));
  } catch (IllegalArgumentException e) {
   // Invalid region, try table
   getAdmin().compact(TableName.valueOf(getBytes(tableNameOrRegionName)));
  }
 } catch (IOException e) {
  LOG.warn(e.getMessage(), e);
  throw getIOError(e);
 }
}

代码示例来源:origin: apache/hbase

} else {
 LOG.debug("Compacting region " + region.getRegionNameAsString());
 admin.compactRegion(region.getRegionName());

代码示例来源:origin: apache/hbase

admin.compactRegion(region.getRegionName());

代码示例来源:origin: apache/hbase

this.admin.compactRegion(daughter.getRegionName());
RetryCounter retrier = new RetryCounter(30, 1, TimeUnit.SECONDS);
while (CompactionState.NONE != admin.getCompactionStateForRegion(daughter.getRegionName())

代码示例来源:origin: apache/hbase

count += hrfs.getStoreFiles(colFamily.getName()).size();
ADMIN.compactRegion(mergedRegionInfo.getRegionName());

代码示例来源:origin: com.aliyun.hbase/alihbase-thrift

@Override
public void compact(ByteBuffer tableNameOrRegionName) throws IOError {
 try {
  try {
   getAdmin().compactRegion(getBytes(tableNameOrRegionName));
  } catch (IllegalArgumentException e) {
   // Invalid region, try table
   getAdmin().compact(TableName.valueOf(getBytes(tableNameOrRegionName)));
  }
 } catch (IOException e) {
  LOG.warn(e.getMessage(), e);
  throw getIOError(e);
 }
}

代码示例来源:origin: com.aliyun.hbase/alihbase-thrift

@Override
public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError {
 try {
  try {
   getAdmin().compactRegion(getBytes(tableNameOrRegionName));
  } catch (IllegalArgumentException e) {
   // Invalid region, try table
   getAdmin().compact(TableName.valueOf(getBytes(tableNameOrRegionName)));
  }
 } catch (IOException e) {
  LOG.warn(e.getMessage(), e);
  throw getIOError(e);
 }
}

代码示例来源:origin: org.apache.hbase/hbase-thrift

@Override
public void compact(ByteBuffer tableNameOrRegionName) throws IOError {
 try {
  try {
   getAdmin().compactRegion(getBytes(tableNameOrRegionName));
  } catch (IllegalArgumentException e) {
   // Invalid region, try table
   getAdmin().compact(TableName.valueOf(getBytes(tableNameOrRegionName)));
  }
 } catch (IOException e) {
  LOG.warn(e.getMessage(), e);
  throw getIOError(e);
 }
}

代码示例来源:origin: org.apache.hbase/hbase-thrift

@Override
public void majorCompact(ByteBuffer tableNameOrRegionName) throws IOError {
 try {
  try {
   getAdmin().compactRegion(getBytes(tableNameOrRegionName));
  } catch (IllegalArgumentException e) {
   // Invalid region, try table
   getAdmin().compact(TableName.valueOf(getBytes(tableNameOrRegionName)));
  }
 } catch (IOException e) {
  LOG.warn(e.getMessage(), e);
  throw getIOError(e);
 }
}

代码示例来源:origin: org.apache.hbase/hbase-it

} else {
 LOG.debug("Compacting region " + region.getRegionNameAsString());
 admin.compactRegion(region.getRegionName());

代码示例来源:origin: org.apache.hbase/hbase-server

this.admin.compactRegion(daughter.getRegionName());
RetryCounter retrier = new RetryCounter(30, 1, TimeUnit.SECONDS);
while (CompactionState.NONE != admin.getCompactionStateForRegion(daughter.getRegionName())

代码示例来源:origin: harbby/presto-connectors

admin.compactRegion(Bytes.toBytes(key));
} else {
 admin.compact(TableName.valueOf(fqtn));

代码示例来源:origin: org.apache.hbase/hbase-server

count += hrfs.getStoreFiles(colFamily.getName()).size();
ADMIN.compactRegion(mergedRegionInfo.getRegionName());

相关文章

Admin类方法