org.apache.hadoop.hbase.quotas.QuotaRetriever.open()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(58)

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

QuotaRetriever.open介绍

[英]Open a QuotaRetriever with no filter, all the quota settings will be returned.
[中]打开不带过滤器的QuotaRetriever,将返回所有配额设置。

代码示例

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

/**
 * Open a QuotaRetriever with no filter, all the quota settings will be returned.
 * @param conf Configuration object to use.
 * @return the QuotaRetriever
 * @throws IOException if a remote or network exception occurs
 */
public static QuotaRetriever open(final Configuration conf) throws IOException {
 return open(conf, null);
}

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

@Override
public QuotaRetriever getQuotaRetriever(final QuotaFilter filter) throws IOException {
 return QuotaRetriever.open(conf, filter);
}

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

@Override
public List<QuotaSettings> getQuota(QuotaFilter filter) throws IOException {
 List<QuotaSettings> quotas = new LinkedList<>();
 try (QuotaRetriever retriever = QuotaRetriever.open(conf, filter)) {
  Iterator<QuotaSettings> iterator = retriever.iterator();
  while (iterator.hasNext()) {
   quotas.add(iterator.next());
  }
 }
 return quotas;
}

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

private int countResults(final QuotaFilter filter) throws Exception {
  QuotaRetriever scanner = QuotaRetriever.open(TEST_UTIL.getConfiguration(), filter);
  try {
   int count = 0;
   for (QuotaSettings settings: scanner) {
    LOG.debug(Objects.toString(settings));
    count++;
   }
   return count;
  } finally {
   scanner.close();
  }
 }
}

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

try (Admin admin = conn.getAdmin()) {
 for (QuotaSettings qs : QuotaRetriever.open(conf, filter)) {
  if (qs.getQuotaType() == QuotaType.SPACE) {
   String ns = qs.getNamespace();

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

public int getNumSpaceQuotas() throws Exception {
 QuotaRetriever scanner = QuotaRetriever.open(TEST_UTIL.getConfiguration());
 int numSpaceQuotas = 0;
 for (QuotaSettings quotaSettings : scanner) {
  if (quotaSettings.getQuotaType() == QuotaType.SPACE) {
   numSpaceQuotas++;
  }
 }
 return numSpaceQuotas;
}

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

public int getThrottleQuotas() throws Exception {
 QuotaRetriever scanner = QuotaRetriever.open(TEST_UTIL.getConfiguration());
 int throttleQuotas = 0;
 for (QuotaSettings quotaSettings : scanner) {
  if (quotaSettings.getQuotaType() == QuotaType.THROTTLE) {
   throttleQuotas++;
  }
 }
 return throttleQuotas;
}

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

private void verifyNotFetchableViaAPI(Admin admin) throws Exception {
 // Verify that we can also not fetch it via the API
 try (QuotaRetriever quotaScanner = QuotaRetriever.open(admin.getConfiguration())) {
  assertNull("Did not expect to find a quota entry", quotaScanner.next());
 }
}

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

private void verifyFetchableViaAPI(Admin admin, ThrottleType type, long limit, TimeUnit tu)
  throws Exception {
 // Verify we can retrieve the new quota via the QuotaRetriever API
 try (QuotaRetriever quotaScanner = QuotaRetriever.open(admin.getConfiguration())) {
  assertRPCQuota(type, limit, tu, Iterables.getOnlyElement(quotaScanner));
 }
}

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

/**
 * Returns the number of quotas defined in the HBase quota table.
 */
long listNumDefinedQuotas(Connection conn) throws IOException {
 QuotaRetriever scanner = QuotaRetriever.open(conn.getConfiguration());
 try {
  return Iterables.size(scanner);
 } finally {
  if (scanner != null) {
   scanner.close();
  }
 }
}

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

@Override
public QuotaRetriever getQuotaRetriever(final QuotaFilter filter) throws IOException {
 return QuotaRetriever.open(conf, filter);
}

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

/**
 * Open a QuotaRetriever with no filter, all the quota settings will be returned.
 * @param conf Configuration object to use.
 * @return the QuotaRetriever
 * @throws IOException if a remote or network exception occurs
 */
public static QuotaRetriever open(final Configuration conf) throws IOException {
 return open(conf, null);
}

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

QuotaSettings getTableSpaceQuota(Connection conn, TableName tn) throws IOException {
 try (QuotaRetriever scanner = QuotaRetriever.open(
   conn.getConfiguration(), new QuotaFilter().setTableFilter(tn.getNameAsString()))) {
  for (QuotaSettings setting : scanner) {
   if (setting.getTableName().equals(tn) && setting.getQuotaType() == QuotaType.SPACE) {
    return setting;
   }
  }
  return null;
 }
}

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

} else {
 QuotaRetriever scanner = QuotaRetriever.open(conn.getConfiguration());
 try {
  for (QuotaSettings quotaSettings : scanner) {

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

@Override
public List<QuotaSettings> getQuota(QuotaFilter filter) throws IOException {
 List<QuotaSettings> quotas = new LinkedList<>();
 try (QuotaRetriever retriever = QuotaRetriever.open(conf, filter)) {
  Iterator<QuotaSettings> iterator = retriever.iterator();
  while (iterator.hasNext()) {
   quotas.add(iterator.next());
  }
 }
 return quotas;
}

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

QuotaRetriever scanner = QuotaRetriever.open(admin.getConfiguration());
try {
 assertSpaceQuota(sizeLimit, violationPolicy, Iterables.getOnlyElement(scanner));
scanner = QuotaRetriever.open(admin.getConfiguration());
try {
 assertNull("Did not expect to find a quota entry", scanner.next());

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

QuotaRetriever quotaScanner = QuotaRetriever.open(admin.getConfiguration());
try {
 assertSpaceQuota(originalSizeLimit, violationPolicy, Iterables.getOnlyElement(quotaScanner));
quotaScanner = QuotaRetriever.open(admin.getConfiguration());
try {
 assertSpaceQuota(newSizeLimit, newViolationPolicy, Iterables.getOnlyElement(quotaScanner));
quotaScanner = QuotaRetriever.open(admin.getConfiguration());
try {
 assertNull("Did not expect to find a quota entry", quotaScanner.next());

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

admin.setQuota(QuotaSettingsFactory.bypassGlobals(userName, true));
try (QuotaRetriever scanner = QuotaRetriever.open(TEST_UTIL.getConfiguration())) {
 int countThrottle = 0;
 int countGlobalBypass = 0;

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

30, TimeUnit.SECONDS));
int count = 0;
QuotaRetriever scanner = QuotaRetriever.open(TEST_UTIL.getConfiguration(), rsFilter);
try {
 for (QuotaSettings settings : scanner) {

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

admin.setQuota(QuotaSettingsFactory.bypassGlobals(userName, true));
try (QuotaRetriever scanner = QuotaRetriever.open(TEST_UTIL.getConfiguration())) {
 int countThrottle = 0;
 int countGlobalBypass = 0;

相关文章