Package org.apache.hadoop.hbase.quotas

Class QuotaRetriever

java.lang.Object

org.apache.hadoop.hbase.quotas.QuotaRetriever

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<QuotaSettings>

@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	Description
private class	QuotaRetriever.Iter

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
QuotaRetriever(org.apache.hadoop.conf.Configuration conf, Scan scan)
QuotaRetriever(Connection conn)
QuotaRetriever(Connection conn, Scan scan)
QuotaRetriever(Connection conn, QuotaFilter filter)

Method Summary

Modifier and Type	Method	Description
void	close()
private void	init(Connection conn, Scan scan)
Iterator<QuotaSettings>	iterator()
QuotaSettings	next()
static QuotaRetriever	open(org.apache.hadoop.conf.Configuration conf)	Deprecated. Since 3.0.0, will be removed in 4.0.0.
static QuotaRetriever	open(org.apache.hadoop.conf.Configuration conf, QuotaFilter filter)	Deprecated. Since 3.0.0, will be removed in 4.0.0.

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 Details

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 final boolean isManagedConnection

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

Constructor Details

QuotaRetriever

public QuotaRetriever(Connection conn)
               throws IOException

Throws:

IOException

QuotaRetriever

public QuotaRetriever(Connection conn,
 QuotaFilter filter)
               throws IOException

Throws:

IOException

QuotaRetriever

public QuotaRetriever(Connection conn,
 Scan scan)
               throws IOException

Throws:

IOException

QuotaRetriever

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

Throws:

IOException

Method Details

init

private void init(Connection conn,
 Scan scan)
           throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

next

public QuotaSettings next()
                   throws IOException

Throws:

IOException

iterator

public Iterator<QuotaSettings> iterator()

Specified by:

iterator in interface Iterable<QuotaSettings>

open

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

Deprecated.

Since 3.0.0, will be removed in 4.0.0. Use QuotaRetriever(Configuration, Scan) instead.

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

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

Deprecated.

Since 3.0.0, will be removed in 4.0.0. Use QuotaRetriever(Configuration, Scan) instead.

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