本文整理了Java中org.apache.hadoop.hbase.client.Admin.compactRegion()
方法的一些代码示例,展示了Admin.compactRegion()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Admin.compactRegion()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.client.Admin
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!