org.apache.hadoop.hbase.hbql.impl
Class Query<T>

java.lang.Object
  org.apache.hadoop.hbase.hbql.impl.Query<T>

public class Query<T>
extends Object

Method Summary

protected T	callOnEachRow(T val)
protected void	callOnException(HBqlException e)
protected void	callOnQueryComplete()
HConnectionImpl	getHConnectionImpl()
List<QueryListener<T>>	getQueryListeners()
List<RowRequest>	getRowRequestList()
SelectStatement	getSelectStmt()
static <E> Query<E>	newQuery(HConnectionImpl conn, SelectStatement selectStatement, Class clazz, QueryListener<E>... listeners)
HResultSet<T>	newResultSet(boolean ignoreQueryExecutor)

Methods inherited from class java.lang.Object

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

Method Detail

newQuery

public static <E> Query<E> newQuery(HConnectionImpl conn,
                                    SelectStatement selectStatement,
                                    Class clazz,
                                    QueryListener<E>... listeners)
                         throws HBqlException

Throws:

HBqlException

getHConnectionImpl

public HConnectionImpl getHConnectionImpl()

getSelectStmt

public SelectStatement getSelectStmt()

getRowRequestList

public List<RowRequest> getRowRequestList()
                                   throws HBqlException

Throws:

HBqlException

getQueryListeners

public List<QueryListener<T>> getQueryListeners()

newResultSet

public HResultSet<T> newResultSet(boolean ignoreQueryExecutor)
                           throws HBqlException

Throws:

HBqlException

callOnEachRow

protected T callOnEachRow(T val)

callOnQueryComplete

protected void callOnQueryComplete()

callOnException

protected void callOnException(HBqlException e)