org.apache.hadoop.hbase.rest

Class RowResource

java.lang.Object

org.apache.hadoop.hbase.rest.ResourceBase

org.apache.hadoop.hbase.rest.RowResource

All Implemented Interfaces:

Constants

@InterfaceAudience.Private
public class RowResource
extends ResourceBase

Field Summary

Fields

Modifier and Type	Field and Description
private String	check
private static String	CHECK_APPEND
private static String	CHECK_DELETE
private static String	CHECK_INCREMENT
private static String	CHECK_PUT
private static org.slf4j.Logger	LOG
private boolean	returnResult
private RowSpec	rowspec
private TableResource	tableResource

Fields inherited from class org.apache.hadoop.hbase.rest.ResourceBase

accessDeniedClazz, servlet

Fields inherited from interface org.apache.hadoop.hbase.rest.Constants

CRLF, CUSTOM_FILTERS, DEFAULT_LISTEN_PORT, DEFAULT_MAX_AGE, DEFAULT_REST_CLIENT_CONN_TIMEOUT, DEFAULT_REST_CLIENT_SOCKET_TIMEOUT, FILTER_CLASSES, MIMETYPE_BINARY, MIMETYPE_HTML, MIMETYPE_JSON, MIMETYPE_PROTOBUF, MIMETYPE_PROTOBUF_IETF, MIMETYPE_TEXT, MIMETYPE_XML, NOCACHE_PARAM_NAME, REST_AUTHENTICATION_PRINCIPAL, REST_AUTHENTICATION_TYPE, REST_CLIENT_CONN_TIMEOUT, REST_CLIENT_SOCKET_TIMEOUT, REST_CONNECTOR_ACCEPT_QUEUE_SIZE, REST_DNS_INTERFACE, REST_DNS_NAMESERVER, REST_KERBEROS_PRINCIPAL, REST_KEYTAB_FILE, REST_SSL_ENABLED, REST_SSL_EXCLUDE_CIPHER_SUITES, REST_SSL_EXCLUDE_PROTOCOLS, REST_SSL_INCLUDE_CIPHER_SUITES, REST_SSL_INCLUDE_PROTOCOLS, REST_SSL_KEYSTORE_KEYPASSWORD, REST_SSL_KEYSTORE_PASSWORD, REST_SSL_KEYSTORE_STORE, REST_SSL_KEYSTORE_TYPE, REST_SSL_TRUSTSTORE_PASSWORD, REST_SSL_TRUSTSTORE_STORE, REST_SSL_TRUSTSTORE_TYPE, REST_THREAD_POOL_TASK_QUEUE_SIZE, REST_THREAD_POOL_THREAD_IDLE_TIMEOUT, REST_THREAD_POOL_THREADS_MAX, REST_THREAD_POOL_THREADS_MIN, ROW_KEYS_PARAM_NAME, SCAN_BATCH_SIZE, SCAN_CACHE_BLOCKS, SCAN_COLUMN, SCAN_END_ROW, SCAN_END_TIME, SCAN_FETCH_SIZE, SCAN_FILTER, SCAN_LIMIT, SCAN_MAX_VERSIONS, SCAN_REVERSED, SCAN_START_ROW, SCAN_START_TIME, VERSION_STRING

Constructor Summary

Constructors

Constructor and Description
RowResource(TableResource tableResource, String rowspec, String versions, String check, String returnResult) Constructor nnnnnn

Method Summary

Modifier and Type	Method and Description
(package private) org.apache.hbase.thirdparty.javax.ws.rs.core.Response	append(CellSetModel model) Validates the input request parameters, parses columns from CellSetModel, and invokes Append on HTable.
(package private) org.apache.hbase.thirdparty.javax.ws.rs.core.Response	checkAndDelete(CellSetModel model) Validates the input request parameters, parses columns from CellSetModel, and invokes checkAndDelete on HTable.
(package private) org.apache.hbase.thirdparty.javax.ws.rs.core.Response	checkAndPut(CellSetModel model) Validates the input request parameters, parses columns from CellSetModel, and invokes checkAndPut on HTable.
org.apache.hbase.thirdparty.javax.ws.rs.core.Response	delete(org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)
org.apache.hbase.thirdparty.javax.ws.rs.core.Response	get(org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)
org.apache.hbase.thirdparty.javax.ws.rs.core.Response	getBinary(org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)
(package private) org.apache.hbase.thirdparty.javax.ws.rs.core.Response	increment(CellSetModel model) Validates the input request parameters, parses columns from CellSetModel, and invokes Increment on HTable.
org.apache.hbase.thirdparty.javax.ws.rs.core.Response	post(CellSetModel model, org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)
org.apache.hbase.thirdparty.javax.ws.rs.core.Response	postBinary(byte[] message, org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo, org.apache.hbase.thirdparty.javax.ws.rs.core.HttpHeaders headers)
org.apache.hbase.thirdparty.javax.ws.rs.core.Response	put(CellSetModel model, org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)
org.apache.hbase.thirdparty.javax.ws.rs.core.Response	putBinary(byte[] message, org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo, org.apache.hbase.thirdparty.javax.ws.rs.core.HttpHeaders headers)
(package private) org.apache.hbase.thirdparty.javax.ws.rs.core.Response	update(CellSetModel model, boolean replace)
(package private) org.apache.hbase.thirdparty.javax.ws.rs.core.Response	updateBinary(byte[] message, org.apache.hbase.thirdparty.javax.ws.rs.core.HttpHeaders headers, boolean replace)

Methods inherited from class org.apache.hadoop.hbase.rest.ResourceBase

processException

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

CHECK_PUT

private static final String CHECK_PUT

See Also:

Constant Field Values

CHECK_DELETE

private static final String CHECK_DELETE

See Also:

Constant Field Values

CHECK_APPEND

private static final String CHECK_APPEND

See Also:

Constant Field Values

CHECK_INCREMENT

private static final String CHECK_INCREMENT

See Also:

Constant Field Values

tableResource

private TableResource tableResource

rowspec

private RowSpec rowspec

check

private String check

returnResult

private boolean returnResult

Constructor Detail

RowResource

public RowResource(TableResource tableResource,
                   String rowspec,
                   String versions,
                   String check,
                   String returnResult)
            throws IOException

Constructor nnnnnn

Throws:

IOException

Method Detail

get

@GET
 @Produces(value={"text/xml","application/json","application/x-protobuf","application/protobuf"})
public org.apache.hbase.thirdparty.javax.ws.rs.core.Response get(@Context
                                                                                                                                                                        org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)

getBinary

@GET
 @Produces(value="application/octet-stream")
public org.apache.hbase.thirdparty.javax.ws.rs.core.Response getBinary(@Context
                                                                                                                         org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)

update

org.apache.hbase.thirdparty.javax.ws.rs.core.Response update(CellSetModel model,
                                                             boolean replace)

updateBinary

org.apache.hbase.thirdparty.javax.ws.rs.core.Response updateBinary(byte[] message,
                                                                   org.apache.hbase.thirdparty.javax.ws.rs.core.HttpHeaders headers,
                                                                   boolean replace)

put

@PUT
 @Consumes(value={"text/xml","application/json","application/x-protobuf","application/protobuf"})
public org.apache.hbase.thirdparty.javax.ws.rs.core.Response put(CellSetModel model,
                                                                                                                                                                        @Context
                                                                                                                                                                        org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)

putBinary

@PUT
 @Consumes(value="application/octet-stream")
public org.apache.hbase.thirdparty.javax.ws.rs.core.Response putBinary(byte[] message,
                                                                                                                         @Context
                                                                                                                         org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo,
                                                                                                                         @Context
                                                                                                                         org.apache.hbase.thirdparty.javax.ws.rs.core.HttpHeaders headers)

post

@POST
 @Consumes(value={"text/xml","application/json","application/x-protobuf","application/protobuf"})
public org.apache.hbase.thirdparty.javax.ws.rs.core.Response post(CellSetModel model,
                                                                                                                                                                          @Context
                                                                                                                                                                          org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)

postBinary

@POST
 @Consumes(value="application/octet-stream")
public org.apache.hbase.thirdparty.javax.ws.rs.core.Response postBinary(byte[] message,
                                                                                                                           @Context
                                                                                                                           org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo,
                                                                                                                           @Context
                                                                                                                           org.apache.hbase.thirdparty.javax.ws.rs.core.HttpHeaders headers)

delete

@DELETE
public org.apache.hbase.thirdparty.javax.ws.rs.core.Response delete(@Context
                                                                            org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)

checkAndPut

org.apache.hbase.thirdparty.javax.ws.rs.core.Response checkAndPut(CellSetModel model)

Validates the input request parameters, parses columns from CellSetModel, and invokes checkAndPut on HTable.

Parameters:

model - instance of CellSetModel

Returns:

Response 200 OK, 304 Not modified, 400 Bad request

checkAndDelete

org.apache.hbase.thirdparty.javax.ws.rs.core.Response checkAndDelete(CellSetModel model)

Validates the input request parameters, parses columns from CellSetModel, and invokes checkAndDelete on HTable.

Parameters:

model - instance of CellSetModel

Returns:

Response 200 OK, 304 Not modified, 400 Bad request

append

org.apache.hbase.thirdparty.javax.ws.rs.core.Response append(CellSetModel model)

Validates the input request parameters, parses columns from CellSetModel, and invokes Append on HTable.

Parameters:

model - instance of CellSetModel

Returns:

Response 200 OK, 304 Not modified, 400 Bad request

increment

org.apache.hbase.thirdparty.javax.ws.rs.core.Response increment(CellSetModel model)

Validates the input request parameters, parses columns from CellSetModel, and invokes Increment on HTable.

Parameters:

model - instance of CellSetModel

Returns:

Response 200 OK, 304 Not modified, 400 Bad request