org.apache.hadoop.hbase.rest.client

Class Client

java.lang.Object

org.apache.hadoop.hbase.rest.client.Client

@InterfaceAudience.Public
public class Client
extends Object

A wrapper around HttpClient which provides some useful function and semantics for interacting with the REST gateway.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Client.ClientTrustStoreInitializationException

Field Summary

Fields

Modifier and Type	Field and Description
private static String	AUTH_COOKIE
private static String	AUTH_COOKIE_EQ
private Cluster	cluster
private org.apache.hadoop.conf.Configuration	conf
private static String	COOKIE
static org.apache.http.Header[]	EMPTY_HEADER_ARRAY
private Map<String,String>	extraHeaders
private org.apache.http.client.HttpClient	httpClient
private org.apache.http.client.methods.HttpGet	httpGet
private static org.slf4j.Logger	LOG
private org.apache.http.HttpResponse	resp
private boolean	sslEnabled

Constructor Summary

Constructors

Constructor and Description
Client() Default Constructor
Client(Cluster cluster) Constructor
Client(Cluster cluster, boolean sslEnabled) Constructor
Client(Cluster cluster, org.apache.hadoop.conf.Configuration conf, boolean sslEnabled) Constructor
Client(Cluster cluster, org.apache.hadoop.conf.Configuration conf, String trustStorePath, Optional<String> trustStorePassword, Optional<String> trustStoreType) Constructor, allowing to define custom trust store (only for SSL connections)
Client(Cluster cluster, String trustStorePath, Optional<String> trustStorePassword, Optional<String> trustStoreType) Constructor, allowing to define custom trust store (only for SSL connections)

Method Summary

Modifier and Type	Method and Description
void	addExtraHeader(String name, String value) Add extra headers.
Response	delete(Cluster cluster, String path) Send a DELETE request
Response	delete(Cluster cluster, String path, org.apache.http.Header extraHdr) Send a DELETE request
Response	delete(String path) Send a DELETE request
Response	delete(String path, org.apache.http.Header extraHdr) Send a DELETE request
org.apache.http.HttpResponse	execute(Cluster cluster, org.apache.http.client.methods.HttpUriRequest method, org.apache.http.Header[] headers, String path) Execute a transaction method.
org.apache.http.HttpResponse	executePathOnly(Cluster cluster, org.apache.http.client.methods.HttpUriRequest method, org.apache.http.Header[] headers, String path) Execute a transaction method given only the path.
org.apache.http.HttpResponse	executeURI(org.apache.http.client.methods.HttpUriRequest method, org.apache.http.Header[] headers, String uri) Execute a transaction method given a complete URI.
Response	get(Cluster cluster, String path) Send a GET request
Response	get(Cluster c, String path, org.apache.http.Header[] headers) Send a GET request
Response	get(Cluster cluster, String path, String accept) Send a GET request
Response	get(String path) Send a GET request
Response	get(String path, org.apache.http.Header[] headers) Send a GET request
Response	get(String path, String accept) Send a GET request
Cluster	getCluster() Returns the cluster definition
String	getExtraHeader(String name) Get an extra header value.
Map<String,String>	getExtraHeaders() Get all extra headers (read-only).
org.apache.http.client.HttpClient	getHttpClient() Returns the wrapped HttpClient
static byte[]	getResponseBody(org.apache.http.HttpResponse resp) Returns the response body of the HTTPResponse, if any, as an array of bytes.
Response	head(Cluster cluster, String path, org.apache.http.Header[] headers) Send a HEAD request
Response	head(String path) Send a HEAD request
private void	initialize(Cluster cluster, org.apache.hadoop.conf.Configuration conf, boolean sslEnabled, Optional<KeyStore> trustStore)
private void	injectToken(org.apache.http.client.methods.HttpUriRequest method, org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token token) Helper method that injects an authentication token to send with the method.
private void	negotiate(org.apache.http.client.methods.HttpUriRequest method, String uri) Initiate client side Kerberos negotiation with the server.
Response	post(Cluster cluster, String path, org.apache.http.Header[] headers, byte[] content) Send a POST request
Response	post(Cluster cluster, String path, String contentType, byte[] content) Send a POST request
Response	post(Cluster cluster, String path, String contentType, byte[] content, org.apache.http.Header extraHdr) Send a POST request
Response	post(String path, org.apache.http.Header[] headers, byte[] content) Send a POST request
Response	post(String path, String contentType, byte[] content) Send a POST request
Response	post(String path, String contentType, byte[] content, org.apache.http.Header extraHdr) Send a POST request
Response	put(Cluster cluster, String path, org.apache.http.Header[] headers, byte[] content) Send a PUT request
Response	put(Cluster cluster, String path, String contentType, byte[] content) Send a PUT request
Response	put(Cluster cluster, String path, String contentType, byte[] content, org.apache.http.Header extraHdr) Send a PUT request
Response	put(String path, org.apache.http.Header[] headers, byte[] content) Send a PUT request
Response	put(String path, String contentType, byte[] content) Send a PUT request
Response	put(String path, String contentType, byte[] content, org.apache.http.Header extraHdr) Send a PUT request
void	removeExtraHeader(String name) Remove an extra header.
void	setCluster(Cluster cluster)
void	shutdown() Shut down the client.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EMPTY_HEADER_ARRAY

public static final org.apache.http.Header[] EMPTY_HEADER_ARRAY

LOG

private static final org.slf4j.Logger LOG

httpClient

private org.apache.http.client.HttpClient httpClient

cluster

private Cluster cluster

conf

private org.apache.hadoop.conf.Configuration conf

sslEnabled

private boolean sslEnabled

resp

private org.apache.http.HttpResponse resp

httpGet

private org.apache.http.client.methods.HttpGet httpGet

extraHeaders

private Map<String,String> extraHeaders

AUTH_COOKIE

private static final String AUTH_COOKIE

See Also:

Constant Field Values

AUTH_COOKIE_EQ

private static final String AUTH_COOKIE_EQ

See Also:

Constant Field Values

COOKIE

private static final String COOKIE

See Also:

Constant Field Values

Constructor Detail

Client

public Client()

Default Constructor

Client

public Client(Cluster cluster)

Constructor

Parameters:

cluster - the cluster definition

Client

public Client(Cluster cluster,
              boolean sslEnabled)

Constructor

Parameters:

cluster - the cluster definition

sslEnabled - enable SSL or not

Client

public Client(Cluster cluster,
              org.apache.hadoop.conf.Configuration conf,
              boolean sslEnabled)

Constructor

Parameters:

cluster - the cluster definition

conf - Configuration

sslEnabled - enable SSL or not

Client

public Client(Cluster cluster,
              String trustStorePath,
              Optional<String> trustStorePassword,
              Optional<String> trustStoreType)

Constructor, allowing to define custom trust store (only for SSL connections)

Parameters:

cluster - the cluster definition

trustStorePath - custom trust store to use for SSL connections

trustStorePassword - password to use for custom trust store

trustStoreType - type of custom trust store

Throws:

Client.ClientTrustStoreInitializationException - if the trust store file can not be loaded

Client

public Client(Cluster cluster,
              org.apache.hadoop.conf.Configuration conf,
              String trustStorePath,
              Optional<String> trustStorePassword,
              Optional<String> trustStoreType)

Constructor, allowing to define custom trust store (only for SSL connections)

Parameters:

cluster - the cluster definition

conf - Configuration

trustStorePath - custom trust store to use for SSL connections

trustStorePassword - password to use for custom trust store

trustStoreType - type of custom trust store

Throws:

Client.ClientTrustStoreInitializationException - if the trust store file can not be loaded

Method Detail

initialize

private void initialize(Cluster cluster,
                        org.apache.hadoop.conf.Configuration conf,
                        boolean sslEnabled,
                        Optional<KeyStore> trustStore)

shutdown

public void shutdown()

Shut down the client. Close any open persistent connections.

getHttpClient

public org.apache.http.client.HttpClient getHttpClient()

Returns the wrapped HttpClient

addExtraHeader

public void addExtraHeader(String name,
                           String value)

Add extra headers. These extra headers will be applied to all http methods before they are removed. If any header is not used any more, client needs to remove it explicitly.

getExtraHeader

public String getExtraHeader(String name)

Get an extra header value.

getExtraHeaders

public Map<String,String> getExtraHeaders()

Get all extra headers (read-only).

removeExtraHeader

public void removeExtraHeader(String name)

Remove an extra header.

executePathOnly

public org.apache.http.HttpResponse executePathOnly(Cluster cluster,
                                                    org.apache.http.client.methods.HttpUriRequest method,
                                                    org.apache.http.Header[] headers,
                                                    String path)
                                             throws IOException

Execute a transaction method given only the path. Will select at random one of the members of the supplied cluster definition and iterate through the list until a transaction can be successfully completed. The definition of success here is a complete HTTP transaction, irrespective of result code.

Parameters:

cluster - the cluster definition

method - the transaction method

headers - HTTP header values to send

path - the properly urlencoded path

Returns:

the HTTP response code n

Throws:

IOException

executeURI

public org.apache.http.HttpResponse executeURI(org.apache.http.client.methods.HttpUriRequest method,
                                               org.apache.http.Header[] headers,
                                               String uri)
                                        throws IOException

Execute a transaction method given a complete URI.

Parameters:

method - the transaction method

headers - HTTP header values to send

uri - a properly urlencoded URI

Returns:

the HTTP response code n

Throws:

IOException

execute

public org.apache.http.HttpResponse execute(Cluster cluster,
                                            org.apache.http.client.methods.HttpUriRequest method,
                                            org.apache.http.Header[] headers,
                                            String path)
                                     throws IOException

Execute a transaction method. Will call either executePathOnly or executeURI depending on whether a path only is supplied in 'path', or if a complete URI is passed instead, respectively.

Parameters:

cluster - the cluster definition

method - the HTTP method

headers - HTTP header values to send

path - the properly urlencoded path or URI

Returns:

the HTTP response code n

Throws:

IOException

negotiate

private void negotiate(org.apache.http.client.methods.HttpUriRequest method,
                       String uri)
                throws IOException

Initiate client side Kerberos negotiation with the server.

Parameters:

method - method to inject the authentication token into.

uri - the String to parse as a URL.

Throws:

IOException - if unknown protocol is found.

injectToken

private void injectToken(org.apache.http.client.methods.HttpUriRequest method,
                         org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token token)

Helper method that injects an authentication token to send with the method.

Parameters:

method - method to inject the authentication token into.

token - authentication token to inject.

getCluster

public Cluster getCluster()

Returns the cluster definition

setCluster

public void setCluster(Cluster cluster)

Parameters:

cluster - the cluster definition

head

public Response head(String path)
              throws IOException

Send a HEAD request

Parameters:

path - the path or URI

Returns:

a Response object with response detail n

Throws:

IOException

head

public Response head(Cluster cluster,
                     String path,
                     org.apache.http.Header[] headers)
              throws IOException

Send a HEAD request

Parameters:

cluster - the cluster definition

path - the path or URI

headers - the HTTP headers to include in the request

Returns:

a Response object with response detail n

Throws:

IOException

get

public Response get(String path)
             throws IOException

Send a GET request

Parameters:

path - the path or URI

Returns:

a Response object with response detail n

Throws:

IOException

get

public Response get(Cluster cluster,
                    String path)
             throws IOException

Send a GET request

Parameters:

cluster - the cluster definition

path - the path or URI

Returns:

a Response object with response detail n

Throws:

IOException

get

public Response get(String path,
                    String accept)
             throws IOException

Send a GET request

Parameters:

path - the path or URI

accept - Accept header value

Returns:

a Response object with response detail n

Throws:

IOException

get

public Response get(Cluster cluster,
                    String path,
                    String accept)
             throws IOException

Send a GET request

Parameters:

cluster - the cluster definition

path - the path or URI

accept - Accept header value

Returns:

a Response object with response detail n

Throws:

IOException

get

public Response get(String path,
                    org.apache.http.Header[] headers)
             throws IOException

Send a GET request

Parameters:

path - the path or URI

headers - the HTTP headers to include in the request, Accept must be supplied

Returns:

a Response object with response detail n

Throws:

IOException

getResponseBody

public static byte[] getResponseBody(org.apache.http.HttpResponse resp)
                              throws IOException

Returns the response body of the HTTPResponse, if any, as an array of bytes. If response body is not available or cannot be read, returns null Note: This will cause the entire response body to be buffered in memory. A malicious server may easily exhaust all the VM memory. It is strongly recommended, to use getResponseAsStream if the content length of the response is unknown or reasonably large.

Parameters:

resp - HttpResponse

Returns:

The response body, null if body is empty

Throws:

IOException - If an I/O (transport) problem occurs while obtaining the response body.

get

public Response get(Cluster c,
                    String path,
                    org.apache.http.Header[] headers)
             throws IOException

Send a GET request

Parameters:

c - the cluster definition

path - the path or URI

headers - the HTTP headers to include in the request

Returns:

a Response object with response detail n

Throws:

IOException

put

public Response put(String path,
                    String contentType,
                    byte[] content)
             throws IOException

Send a PUT request

Parameters:

path - the path or URI

contentType - the content MIME type

content - the content bytes

Returns:

a Response object with response detail n

Throws:

IOException

put

public Response put(String path,
                    String contentType,
                    byte[] content,
                    org.apache.http.Header extraHdr)
             throws IOException

Send a PUT request

Parameters:

path - the path or URI

contentType - the content MIME type

content - the content bytes

extraHdr - extra Header to send

Returns:

a Response object with response detail n

Throws:

IOException

put

public Response put(Cluster cluster,
                    String path,
                    String contentType,
                    byte[] content)
             throws IOException

Send a PUT request

Parameters:

cluster - the cluster definition

path - the path or URI

contentType - the content MIME type

content - the content bytes

Returns:

a Response object with response detail

Throws:

IOException - for error

put

public Response put(Cluster cluster,
                    String path,
                    String contentType,
                    byte[] content,
                    org.apache.http.Header extraHdr)
             throws IOException

Send a PUT request

Parameters:

cluster - the cluster definition

path - the path or URI

contentType - the content MIME type

content - the content bytes

extraHdr - additional Header to send

Returns:

a Response object with response detail

Throws:

IOException - for error

put

public Response put(String path,
                    org.apache.http.Header[] headers,
                    byte[] content)
             throws IOException

Send a PUT request

Parameters:

path - the path or URI

headers - the HTTP headers to include, Content-Type must be supplied

content - the content bytes

Returns:

a Response object with response detail n

Throws:

IOException

put

public Response put(Cluster cluster,
                    String path,
                    org.apache.http.Header[] headers,
                    byte[] content)
             throws IOException

Send a PUT request

Parameters:

cluster - the cluster definition

path - the path or URI

headers - the HTTP headers to include, Content-Type must be supplied

content - the content bytes

Returns:

a Response object with response detail n

Throws:

IOException

post

public Response post(String path,
                     String contentType,
                     byte[] content)
              throws IOException

Send a POST request

Parameters:

path - the path or URI

contentType - the content MIME type

content - the content bytes

Returns:

a Response object with response detail n

Throws:

IOException

post

public Response post(String path,
                     String contentType,
                     byte[] content,
                     org.apache.http.Header extraHdr)
              throws IOException

Send a POST request

Parameters:

path - the path or URI

contentType - the content MIME type

content - the content bytes

extraHdr - additional Header to send

Returns:

a Response object with response detail n

Throws:

IOException

post

public Response post(Cluster cluster,
                     String path,
                     String contentType,
                     byte[] content)
              throws IOException

Send a POST request

Parameters:

cluster - the cluster definition

path - the path or URI

contentType - the content MIME type

content - the content bytes

Returns:

a Response object with response detail

Throws:

IOException - for error

post

public Response post(Cluster cluster,
                     String path,
                     String contentType,
                     byte[] content,
                     org.apache.http.Header extraHdr)
              throws IOException

Send a POST request

Parameters:

cluster - the cluster definition

path - the path or URI

contentType - the content MIME type

content - the content bytes

extraHdr - additional Header to send

Returns:

a Response object with response detail

Throws:

IOException - for error

post

public Response post(String path,
                     org.apache.http.Header[] headers,
                     byte[] content)
              throws IOException

Send a POST request

Parameters:

path - the path or URI

headers - the HTTP headers to include, Content-Type must be supplied

content - the content bytes

Returns:

a Response object with response detail n

Throws:

IOException

post

public Response post(Cluster cluster,
                     String path,
                     org.apache.http.Header[] headers,
                     byte[] content)
              throws IOException

Send a POST request

Parameters:

cluster - the cluster definition

path - the path or URI

headers - the HTTP headers to include, Content-Type must be supplied

content - the content bytes

Returns:

a Response object with response detail n

Throws:

IOException

delete

public Response delete(String path)
                throws IOException

Send a DELETE request

Parameters:

path - the path or URI

Returns:

a Response object with response detail n

Throws:

IOException

delete

public Response delete(String path,
                       org.apache.http.Header extraHdr)
                throws IOException

Send a DELETE request

Parameters:

path - the path or URI

extraHdr - additional Header to send

Returns:

a Response object with response detail n

Throws:

IOException

delete

public Response delete(Cluster cluster,
                       String path)
                throws IOException

Send a DELETE request

Parameters:

cluster - the cluster definition

path - the path or URI

Returns:

a Response object with response detail

Throws:

IOException - for error

delete

public Response delete(Cluster cluster,
                       String path,
                       org.apache.http.Header extraHdr)
                throws IOException

Send a DELETE request

Parameters:

cluster - the cluster definition

path - the path or URI

Returns:

a Response object with response detail

Throws:

IOException - for error