Field Detail

• client

  final Client client

• conf

  final org.apache.hadoop.conf.Configuration conf

• accessToken

  final String accessToken

• maxRetries

  final int maxRetries

• sleepTime

  final long sleepTime

• versionClusterUnmarshaller

  private static volatile Unmarshaller versionClusterUnmarshaller

Constructor Detail

• RemoteAdmin

  public RemoteAdmin(Client client,
             org.apache.hadoop.conf.Configuration conf)

  Constructor

  Parameters:

  client -

  conf -

• RemoteAdmin

  public RemoteAdmin(Client client,
             org.apache.hadoop.conf.Configuration conf,
             String accessToken)

  Constructor

  Parameters:

  client -

  conf -

  accessToken -

Method Detail

• getUnmarsheller

  static Unmarshaller getUnmarsheller()
                               throws JAXBException

  Throws:

  JAXBException

• isTableAvailable

  public boolean isTableAvailable(String tableName)
                           throws IOException

  Parameters:

  tableName - name of table to check

  Returns:

  true if all regions of the table are available

  Throws:

  IOException - if a remote or network exception occurs

• getRestVersion

  public VersionModel getRestVersion()
                              throws IOException

  Returns:

  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

• getClusterStatus

  public StorageClusterStatusModel getClusterStatus()
                                             throws IOException

  Returns:

  string representing the cluster's version

  Throws:

  IOException - if the endpoint does not exist, there is a timeout, or some other general failure mode

• getClusterVersion

  public StorageClusterVersionModel getClusterVersion()
                                               throws IOException

  Returns:

  string representing the cluster's version

  Throws:

  IOException - if the endpoint does not exist, there is a timeout, or some other general failure mode

• isTableAvailable

  public boolean isTableAvailable(byte[] tableName)
                           throws IOException

  Parameters:

  tableName - name of table to check

  Returns:

  true if all regions of the table are available

  Throws:

  IOException - if a remote or network exception occurs

• createTable

  public void createTable(HTableDescriptor desc)
                   throws IOException

  Creates a new table.

  Parameters:

  desc - table descriptor for table

  Throws:

  IOException - if a remote or network exception occurs

• deleteTable

  public void deleteTable(String tableName)
                   throws IOException

  Deletes a table.

  Parameters:

  tableName - name of table to delete

  Throws:

  IOException - if a remote or network exception occurs

• deleteTable

  public void deleteTable(byte[] tableName)
                   throws IOException

  Deletes a table.

  Parameters:

  tableName - name of table to delete

  Throws:

  IOException - if a remote or network exception occurs

• getTableList

  public TableListModel getTableList()
                              throws IOException

  Returns:

  string representing the cluster's version

  Throws:

  IOException - if the endpoint does not exist, there is a timeout, or some other general failure mode

• getInputStream

  private XMLStreamReader getInputStream(Response response)
                                  throws IOException

  Convert the REST server's response to an XML reader.

  Parameters:

  response - The REST server's response.

  Returns:

  A reader over the parsed XML document.

  Throws:

  IOException - If the document fails to parse