org.apache.hadoop.hbase.quotas

Class QuotaRetriever

java.lang.Object

org.apache.hadoop.hbase.quotas.QuotaRetriever

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<QuotaSettings>

@InterfaceAudience.Public
public class QuotaRetriever
extends Object
implements Closeable, Iterable<QuotaSettings>

Scanner to iterate over the quota settings.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	QuotaRetriever.Iter

Field Summary

Fields

Modifier and Type	Field and Description
private Queue<QuotaSettings>	cache
private Connection	connection Connection to use.
private boolean	isManagedConnection Should QutoaRetriever manage the state of the connection, or leave it be.
private static org.slf4j.Logger	LOG
private ResultScanner	scanner
private Table	table

Constructor Summary

Constructors

Constructor and Description
QuotaRetriever()

Method Summary

Modifier and Type	Method and Description
void	close()
(package private) void	init(org.apache.hadoop.conf.Configuration conf, Scan scan)
(package private) void	init(Connection conn, Scan scan)
Iterator<QuotaSettings>	iterator()
QuotaSettings	next()
static QuotaRetriever	open(org.apache.hadoop.conf.Configuration conf) Open a QuotaRetriever with no filter, all the quota settings will be returned.
static QuotaRetriever	open(org.apache.hadoop.conf.Configuration conf, QuotaFilter filter) Open a QuotaRetriever with the specified filter.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

LOG

private static final org.slf4j.Logger LOG

cache

private final Queue<QuotaSettings> cache

scanner

private ResultScanner scanner

connection

private Connection connection

Connection to use. Could pass one in and have this class use it but this class wants to be standalone.

table

private Table table

isManagedConnection

private boolean isManagedConnection

Should QutoaRetriever manage the state of the connection, or leave it be.

Constructor Detail

QuotaRetriever

QuotaRetriever()

Method Detail

init

void init(org.apache.hadoop.conf.Configuration conf,
          Scan scan)
   throws IOException

Throws:

IOException

init

void init(Connection conn,
          Scan scan)
   throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

next

public QuotaSettings next()
                   throws IOException

Throws:

IOException

iterator

public Iterator<QuotaSettings> iterator()

Specified by:

iterator in interface Iterable<QuotaSettings>

open

public static QuotaRetriever open(org.apache.hadoop.conf.Configuration conf)
                           throws IOException

Open a QuotaRetriever with no filter, all the quota settings will be returned.

Parameters:

conf - Configuration object to use.

Returns:

the QuotaRetriever

Throws:

IOException - if a remote or network exception occurs

open

public static QuotaRetriever open(org.apache.hadoop.conf.Configuration conf,
                                  QuotaFilter filter)
                           throws IOException

Open a QuotaRetriever with the specified filter.

Parameters:

conf - Configuration object to use.

filter - the QuotaFilter

Returns:

the QuotaRetriever

Throws:

IOException - if a remote or network exception occurs