Package org.apache.hadoop.hbase.rest

Class ScannerResource

java.lang.Object

org.apache.hadoop.hbase.rest.ResourceBase

org.apache.hadoop.hbase.rest.ScannerResource

All Implemented Interfaces:

Constants

@Private
public class ScannerResource
extends ResourceBase

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private static final com.github.benmanes.caffeine.cache.Cache<String,ScannerInstanceResource>	scanners
(package 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, DEFAULT_REST_SCANNERCACHE_EXPIRE_TIME_MS, DEFAULT_REST_SCANNERCACHE_SIZE, FILTER, FILTER_B64, FILTER_CLASSES, KEY_ENCODING_QUERY_PARAM_NAME, 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_SCANNERCACHE_EXPIRE_TIME, REST_SCANNERCACHE_SIZE, 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_INCLUDE_START_ROW, SCAN_INCLUDE_STOP_ROW, SCAN_LIMIT, SCAN_MAX_VERSIONS, SCAN_REVERSED, SCAN_START_ROW, SCAN_START_TIME, VERSION_STRING

Constructor Summary

Constructors

Constructor	Description
ScannerResource(TableResource tableResource)	Constructor

Method Summary

Modifier and Type	Method	Description
(package private) static boolean	delete(String id)
ScannerInstanceResource	getScannerInstanceResource(String id)
org.apache.hbase.thirdparty.javax.ws.rs.core.Response	post(ScannerModel model, org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)
org.apache.hbase.thirdparty.javax.ws.rs.core.Response	put(ScannerModel model, org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)
(package private) static void	removalListener(String key, ScannerInstanceResource value, com.github.benmanes.caffeine.cache.RemovalCause cause)
private static com.github.benmanes.caffeine.cache.Cache<String,ScannerInstanceResource>	setupScanners()
(package private) org.apache.hbase.thirdparty.javax.ws.rs.core.Response	update(ScannerModel model, boolean replace, org.apache.hbase.thirdparty.javax.ws.rs.core.UriInfo uriInfo)

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 Details

LOG

private static final org.slf4j.Logger LOG

scanners

private static final com.github.benmanes.caffeine.cache.Cache<String,ScannerInstanceResource> scanners

tableResource

TableResource tableResource

Constructor Details

ScannerResource

public ScannerResource(TableResource tableResource)
                throws IOException

Constructor

Throws:

IOException

Method Details

setupScanners

private static com.github.benmanes.caffeine.cache.Cache<String,ScannerInstanceResource> setupScanners()

delete

static boolean delete(String id)

removalListener

static void removalListener(String key,
 ScannerInstanceResource value,
 com.github.benmanes.caffeine.cache.RemovalCause cause)

update

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

put

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

post

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

getScannerInstanceResource

@Path("{scanner: .+}")
public ScannerInstanceResource getScannerInstanceResource(@PathParam("scanner")
 String id)
                                                   throws IOException

Throws:

IOException