Java Constants类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

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

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

示例1: getTableDescriptor

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
public HTableDescriptor getTableDescriptor() throws IOException {
  StringBuilder sb = new StringBuilder();
  sb.append('/');
  sb.append(Bytes.toStringBinary(name));
  sb.append('/');
  sb.append("schema");
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(sb.toString(), Constants.MIMETYPE_PROTOBUF);
    int code = response.getCode();
    switch (code) {
    case 200:
      TableSchemaModel schema = new TableSchemaModel();
      schema.getObjectFromMessage(response.getBody());
      return schema.getTableDescriptor();
    case 509: 
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) { }
      break;
    default:
      throw new IOException("schema request returned " + code);
    }
  }
  throw new IOException("schema request timed out");
}

开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:26，代码来源:RemoteHTable.java

示例2: getTableDescriptor

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
public HTableDescriptor getTableDescriptor() throws IOException {
  StringBuilder sb = new StringBuilder();
  sb.append('/');
  sb.append(Bytes.toStringBinary(name));
  sb.append('/');
  sb.append("schema");
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(sb.toString(), Constants.MIMETYPE_PROTOBUF);
    int code = response.getCode();
    switch (code) {
    case 200:
      TableSchemaModel schema = new TableSchemaModel();
      schema.getObjectFromMessage(response.getBody());
      return schema.getTableDescriptor();
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) { }
      break;
    default:
      throw new IOException("schema request returned " + code);
    }
  }
  throw new IOException("schema request timed out");
}

开发者ID:tenggyut，项目名称:HIndex，代码行数:26，代码来源:RemoteHTable.java

示例3: testFailOnExternalEntities

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
@Test
public void testFailOnExternalEntities() throws Exception {
  final String externalEntitiesXml =
      "<?xml version=\"1.0\" encoding=\"UTF-8\"?>"
      + " <!DOCTYPE foo [ <!ENTITY xxe SYSTEM \"/tmp/foo\"> ] >"
      + " <ClusterVersion>&xee;</ClusterVersion>";
  Client client = mock(Client.class);
  RemoteAdmin admin = new RemoteAdmin(client, HBaseConfiguration.create(), null);
  Response resp = new Response(200, null, Bytes.toBytes(externalEntitiesXml));

  when(client.get("/version/cluster", Constants.MIMETYPE_XML)).thenReturn(resp);

  try {
    admin.getClusterVersion();
    fail("Expected getClusterVersion() to throw an exception");
  } catch (IOException e) {
    assertEquals("Cause of exception ought to be a failure to parse the stream due to our " +
        "invalid external entity. Make sure this isn't just a false positive due to " +
        "implementation. see HBASE-19020.", UnmarshalException.class, e.getCause().getClass());
    final String exceptionText = StringUtils.stringifyException(e);
    final String expectedText = "\"xee\"";
    LOG.debug("exception text: '" + exceptionText + "'", e);
    assertTrue("Exception does not contain expected text", exceptionText.contains(expectedText));
  }
}

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

示例4: getTableDescriptor

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
@Override
public HTableDescriptor getTableDescriptor() throws IOException {
  StringBuilder sb = new StringBuilder();
  sb.append('/');
  sb.append(Bytes.toStringBinary(name));
  sb.append('/');
  sb.append("schema");
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(sb.toString(), Constants.MIMETYPE_PROTOBUF);
    int code = response.getCode();
    switch (code) {
    case 200:
      TableSchemaModel schema = new TableSchemaModel();
      schema.getObjectFromMessage(response.getBody());
      return schema.getTableDescriptor();
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) {
        throw (InterruptedIOException)new InterruptedIOException().initCause(e);
      }
      break;
    default:
      throw new IOException("schema request returned " + code);
    }
  }
  throw new IOException("schema request timed out");
}

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

示例5: getResults

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
private Result[] getResults(String spec) throws IOException {
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(spec, Constants.MIMETYPE_PROTOBUF);
    int code = response.getCode();
    switch (code) {
      case 200:
        CellSetModel model = new CellSetModel();
        model.getObjectFromMessage(response.getBody());
        Result[] results = buildResultFromModel(model);
        if ( results.length > 0) {
          return results;
        }
        // fall through
      case 404:
        return new Result[0];

      case 509:
        try {
          Thread.sleep(sleepTime);
        } catch (InterruptedException e) {
          throw (InterruptedIOException)new InterruptedIOException().initCause(e);
        }
        break;
      default:
        throw new IOException("get request returned " + code);
    }
  }
  throw new IOException("get request timed out");
}

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

示例6: next

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
@Override
public Result[] next(int nbRows) throws IOException {
  StringBuilder sb = new StringBuilder(uri);
  sb.append("?n=");
  sb.append(nbRows);
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(sb.toString(),
      Constants.MIMETYPE_PROTOBUF);
    int code = response.getCode();
    switch (code) {
    case 200:
      CellSetModel model = new CellSetModel();
      model.getObjectFromMessage(response.getBody());
      return buildResultFromModel(model);
    case 204:
    case 206:
      return null;
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) {
        throw (InterruptedIOException)new InterruptedIOException().initCause(e);
      }
      break;
    default:
      throw new IOException("scanner.next request failed with " + code);
    }
  }
  throw new IOException("scanner.next request timed out");
}

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

示例7: checkAndPut

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
@Override
public boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
    byte[] value, Put put) throws IOException {
  // column to check-the-value
  put.add(new KeyValue(row, family, qualifier, value));

  CellSetModel model = buildModelFromPut(put);
  StringBuilder sb = new StringBuilder();
  sb.append('/');
  sb.append(Bytes.toStringBinary(name));
  sb.append('/');
  sb.append(Bytes.toStringBinary(put.getRow()));
  sb.append("?check=put");

  for (int i = 0; i < maxRetries; i++) {
    Response response = client.put(sb.toString(),
      Constants.MIMETYPE_PROTOBUF, model.createProtobufOutput());
    int code = response.getCode();
    switch (code) {
    case 200:
      return true;
    case 304: // NOT-MODIFIED
      return false;
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (final InterruptedException e) {
        throw (InterruptedIOException)new InterruptedIOException().initCause(e);
      }
      break;
    default:
      throw new IOException("checkAndPut request failed with " + code);
    }
  }
  throw new IOException("checkAndPut request timed out");
}

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

示例8: checkAndDelete

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
@Override
public boolean checkAndDelete(byte[] row, byte[] family, byte[] qualifier,
    byte[] value, Delete delete) throws IOException {
  Put put = new Put(row);
  put.setFamilyCellMap(delete.getFamilyCellMap());
  // column to check-the-value
  put.add(new KeyValue(row, family, qualifier, value));
  CellSetModel model = buildModelFromPut(put);
  StringBuilder sb = new StringBuilder();
  sb.append('/');
  sb.append(Bytes.toStringBinary(name));
  sb.append('/');
  sb.append(Bytes.toStringBinary(row));
  sb.append("?check=delete");

  for (int i = 0; i < maxRetries; i++) {
    Response response = client.put(sb.toString(),
      Constants.MIMETYPE_PROTOBUF, model.createProtobufOutput());
    int code = response.getCode();
    switch (code) {
    case 200:
      return true;
    case 304: // NOT-MODIFIED
      return false;
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (final InterruptedException e) {
        throw (InterruptedIOException)new InterruptedIOException().initCause(e);
      }
      break;
    default:
      throw new IOException("checkAndDelete request failed with " + code);
    }
  }
  throw new IOException("checkAndDelete request timed out");
}

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

示例9: getRestVersion

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
/**
 * @return string representing the rest api's version
 * @throws IOException
 *           if the endpoint does not exist, there is a timeout, or some other
 *           general failure mode
 */
public VersionModel getRestVersion() throws IOException {

  StringBuilder path = new StringBuilder();
  path.append('/');
  if (accessToken != null) {
    path.append(accessToken);
    path.append('/');
  }

  path.append("version/rest");

  int code = 0;
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(path.toString(),
        Constants.MIMETYPE_PROTOBUF);
    code = response.getCode();
    switch (code) {
    case 200:

      VersionModel v = new VersionModel();
      return (VersionModel) v.getObjectFromMessage(response.getBody());
    case 404:
      throw new IOException("REST version not found");
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) {
        throw (InterruptedIOException)new InterruptedIOException().initCause(e);
      }
      break;
    default:
      throw new IOException("get request to " + path.toString()
          + " returned " + code);
    }
  }
  throw new IOException("get request to " + path.toString() + " timed out");
}

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

示例10: getClusterStatus

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
/**
 * @return string representing the cluster's version
 * @throws IOException if the endpoint does not exist, there is a timeout, or some other general failure mode
 */
public StorageClusterStatusModel getClusterStatus() throws IOException {

    StringBuilder path = new StringBuilder();
    path.append('/');
    if (accessToken !=null) {
        path.append(accessToken);
        path.append('/');
    }

  path.append("status/cluster");

  int code = 0;
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(path.toString(),
        Constants.MIMETYPE_PROTOBUF);
    code = response.getCode();
    switch (code) {
    case 200:
      StorageClusterStatusModel s = new StorageClusterStatusModel();
      return (StorageClusterStatusModel) s.getObjectFromMessage(response
          .getBody());
    case 404:
      throw new IOException("Cluster version not found");
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) {
        throw (InterruptedIOException)new InterruptedIOException().initCause(e);
      }
      break;
    default:
      throw new IOException("get request to " + path + " returned " + code);
    }
  }
  throw new IOException("get request to " + path + " timed out");
}

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

示例11: isTableAvailable

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
/**
 * @param tableName name of table to check
 * @return true if all regions of the table are available
 * @throws IOException if a remote or network exception occurs
 */
public boolean isTableAvailable(byte[] tableName) throws IOException {
  StringBuilder path = new StringBuilder();
  path.append('/');
  if (accessToken != null) {
    path.append(accessToken);
    path.append('/');
  }
  path.append(Bytes.toStringBinary(tableName));
  path.append('/');
  path.append("exists");
  int code = 0;
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(path.toString(), Constants.MIMETYPE_PROTOBUF);
    code = response.getCode();
    switch (code) {
    case 200:
      return true;
    case 404:
      return false;
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) {
        throw (InterruptedIOException)new InterruptedIOException().initCause(e);
      }
      break;
    default:
      throw new IOException("get request to " + path.toString() + " returned " + code);
    }
  }
  throw new IOException("get request to " + path.toString() + " timed out");
}

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

示例12: createTable

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
/**
 * Creates a new table.
 * @param desc table descriptor for table
 * @throws IOException if a remote or network exception occurs
 */
public void createTable(HTableDescriptor desc)
    throws IOException {
  TableSchemaModel model = new TableSchemaModel(desc);
  StringBuilder path = new StringBuilder();
  path.append('/');
  if (accessToken != null) {
    path.append(accessToken);
    path.append('/');
  }
  path.append(desc.getTableName());
  path.append('/');
  path.append("schema");
  int code = 0;
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.put(path.toString(), Constants.MIMETYPE_PROTOBUF,
      model.createProtobufOutput());
    code = response.getCode();
    switch (code) {
    case 201:
      return;
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) {
        throw (InterruptedIOException)new InterruptedIOException().initCause(e);
      }
      break;
    default:
      throw new IOException("create request to " + path.toString() + " returned " + code);
    }
  }
  throw new IOException("create request to " + path.toString() + " timed out");
}

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

示例13: getTableList

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
/**
 * @return string representing the cluster's version
 * @throws IOException
 *           if the endpoint does not exist, there is a timeout, or some other
 *           general failure mode
 */
public TableListModel getTableList() throws IOException {

  StringBuilder path = new StringBuilder();
  path.append('/');
  if (accessToken != null) {
    path.append(accessToken);
    path.append('/');
  }

  int code = 0;
  for (int i = 0; i < maxRetries; i++) {
    // Response response = client.get(path.toString(),
    // Constants.MIMETYPE_XML);
    Response response = client.get(path.toString(),
        Constants.MIMETYPE_PROTOBUF);
    code = response.getCode();
    switch (code) {
    case 200:
      TableListModel t = new TableListModel();
      return (TableListModel) t.getObjectFromMessage(response.getBody());
    case 404:
      throw new IOException("Table list not found");
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) {
        throw (InterruptedIOException)new InterruptedIOException().initCause(e);
      }
      break;
    default:
      throw new IOException("get request to " + path.toString()
          + " request returned " + code);
    }
  }
  throw new IOException("get request to " + path.toString()
      + " request timed out");
}

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

示例14: getResults

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
private Result[] getResults(String spec) throws IOException {
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(spec, Constants.MIMETYPE_PROTOBUF);
    int code = response.getCode();
    switch (code) {
      case 200:
        CellSetModel model = new CellSetModel();
        model.getObjectFromMessage(response.getBody());
        Result[] results = buildResultFromModel(model);
        if (results.length > 0) {
          return results;
        }
        // fall through
      case 404:
        return new Result[0];

      case 509:
        try {
          Thread.sleep(sleepTime);
        } catch (InterruptedException e) {
        }
        break;
      default:
        throw new IOException("get request returned " + code);
    }
  }
  throw new IOException("get request timed out");
}

开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:29，代码来源:RemoteHTable.java

示例15: next

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
@Override
public Result[] next(int nbRows) throws IOException {
  StringBuilder sb = new StringBuilder(uri);
  sb.append("?n=");
  sb.append(nbRows);
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(sb.toString(),
      Constants.MIMETYPE_PROTOBUF);
    int code = response.getCode();
    switch (code) {
    case 200:
      CellSetModel model = new CellSetModel();
      model.getObjectFromMessage(response.getBody());
      return buildResultFromModel(model);
    case 204:
    case 206:
      return null;
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) { }
      break;
    default:
      throw new IOException("scanner.next request failed with " + code);
    }
  }
  throw new IOException("scanner.next request timed out");
}

开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:29，代码来源:RemoteHTable.java

示例16: checkAndPut

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
public boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
    byte[] value, Put put) throws IOException {
  // column to check-the-value
  put.add(new KeyValue(row, family, qualifier, value));

  CellSetModel model = buildModelFromPut(put);
  StringBuilder sb = new StringBuilder();
  sb.append('/');
  sb.append(Bytes.toStringBinary(name));
  sb.append('/');
  sb.append(Bytes.toStringBinary(put.getRow()));
  sb.append("?check=put");

  for (int i = 0; i < maxRetries; i++) {
    Response response = client.put(sb.toString(),
      Constants.MIMETYPE_PROTOBUF, model.createProtobufOutput());
    int code = response.getCode();
    switch (code) {
    case 200:
      return true;
    case 304: // NOT-MODIFIED
      return false;
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (final InterruptedException e) {
      }
      break;
    default:
      throw new IOException("checkAndPut request failed with " + code);
    }
  }
  throw new IOException("checkAndPut request timed out");
}

开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:35，代码来源:RemoteHTable.java

示例17: checkAndDelete

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
public boolean checkAndDelete(byte[] row, byte[] family, byte[] qualifier,
    byte[] value, Delete delete) throws IOException {
  Put put = new Put(row);
  // column to check-the-value
  put.add(new KeyValue(row, family, qualifier, value));
  CellSetModel model = buildModelFromPut(put);
  StringBuilder sb = new StringBuilder();
  sb.append('/');
  sb.append(Bytes.toStringBinary(name));
  sb.append('/');
  sb.append(Bytes.toStringBinary(row));
  sb.append("?check=delete");

  for (int i = 0; i < maxRetries; i++) {
    Response response = client.put(sb.toString(),
      Constants.MIMETYPE_PROTOBUF, model.createProtobufOutput());
    int code = response.getCode();
    switch (code) {
    case 200:
      return true;
    case 304: // NOT-MODIFIED
      return false;
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (final InterruptedException e) {
      }
      break;
    default:
      throw new IOException("checkAndDelete request failed with " + code);
    }
  }
  throw new IOException("checkAndDelete request timed out");
}

开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:35，代码来源:RemoteHTable.java

示例18: getRestVersion

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
/**
 * @return string representing the rest api's version
 * @throws IOEXception
 *           if the endpoint does not exist, there is a timeout, or some other
 *           general failure mode
 */
public VersionModel getRestVersion() throws IOException {

  StringBuilder path = new StringBuilder();
  path.append('/');
  if (accessToken != null) {
    path.append(accessToken);
    path.append('/');
  }

  path.append("version/rest");

  int code = 0;
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(path.toString(),
        Constants.MIMETYPE_PROTOBUF);
    code = response.getCode();
    switch (code) {
    case 200:

      VersionModel v = new VersionModel();
      return (VersionModel) v.getObjectFromMessage(response.getBody());
    case 404:
      throw new IOException("REST version not found");
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) {
      }
      break;
    default:
      throw new IOException("get request to " + path.toString()
          + " returned " + code);
    }
  }
  throw new IOException("get request to " + path.toString() + " timed out");
}

开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:43，代码来源:RemoteAdmin.java

示例19: getClusterStatus

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
/**
 * @return string representing the cluster's version
 * @throws IOEXception if the endpoint does not exist, there is a timeout, or some other general failure mode
 */
public StorageClusterStatusModel getClusterStatus() throws IOException {

    StringBuilder path = new StringBuilder();
    path.append('/');
    if (accessToken !=null) {
        path.append(accessToken);
        path.append('/');
    }

  path.append("status/cluster");

  int code = 0;
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(path.toString(),
        Constants.MIMETYPE_PROTOBUF);
    code = response.getCode();
    switch (code) {
    case 200:
      StorageClusterStatusModel s = new StorageClusterStatusModel();
      return (StorageClusterStatusModel) s.getObjectFromMessage(response
          .getBody());
    case 404:
      throw new IOException("Cluster version not found");
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) {
      }
      break;
    default:
      throw new IOException("get request to " + path + " returned " + code);
    }
  }
  throw new IOException("get request to " + path + " timed out");
}

开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:40，代码来源:RemoteAdmin.java

示例20: isTableAvailable

import org.apache.hadoop.hbase.rest.Constants; //导入依赖的package包/类
/**
 * @param tableName name of table to check
 * @return true if all regions of the table are available
 * @throws IOException if a remote or network exception occurs
 */
public boolean isTableAvailable(byte[] tableName) throws IOException {
  StringBuilder path = new StringBuilder();
  path.append('/');
  if (accessToken != null) {
    path.append(accessToken);
    path.append('/');
  }
  path.append(Bytes.toStringBinary(tableName));
  path.append('/');
  path.append("exists");
  int code = 0;
  for (int i = 0; i < maxRetries; i++) {
    Response response = client.get(path.toString(), Constants.MIMETYPE_PROTOBUF);
    code = response.getCode();
    switch (code) {
    case 200:
      return true;
    case 404:
      return false;
    case 509:
      try {
        Thread.sleep(sleepTime);
      } catch (InterruptedException e) { }
      break;
    default:
      throw new IOException("get request to " + path.toString() + " returned " + code);
    }
  }
  throw new IOException("get request to " + path.toString() + " timed out");
}

开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:36，代码来源:RemoteAdmin.java

注：本文中的org.apache.hadoop.hbase.rest.Constants类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java EtchedBorderUIResource类代码示例发布时间：2022-05-21

Java GenericContainer类代码示例发布时间：2022-05-21

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：17922|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9551|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8120|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8500|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8403|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9290|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8367|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7796|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8349|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7354|2022-11-06

客服电话

电子邮件

Java Constants类代码示例

示例1: getTableDescriptor

示例2: getTableDescriptor

示例3: testFailOnExternalEntities

示例4: getTableDescriptor

示例5: getResults

示例6: next

示例7: checkAndPut

示例8: checkAndDelete

示例9: getRestVersion

示例10: getClusterStatus

示例11: isTableAvailable

示例12: createTable

示例13: getTableList

示例14: getResults

示例15: next

示例16: checkAndPut

示例17: checkAndDelete

示例18: getRestVersion

示例19: getClusterStatus

示例20: isTableAvailable

请发表评论

全部评论

上一篇：

下一篇：

Delphi 2010 lite加装帮助的方法

CVE-2022-29900

PacktPublishing/Python-Machine-Learning-

IMSGlobal/LTI-Tool-Provider-Library-PHP

sussillo/hfopt-matlab: A parallel, cpu-b

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053