org.apache.hadoop.hbase.hbql.client
Interface HConnection

All Known Implementing Classes:

HConnectionImpl

public interface HConnection

Method Summary

void	close()
HStatement	createStatement()
void	disableTable(String tableName)
void	dropIndexForMapping(String indexName, String mappingName)
void	dropIndexForTable(String tableName, String indexName)
boolean	dropMapping(String mappingName)
void	dropTable(String tableName)
void	enableTable(String tableName)
ExecutionResults	execute(String sql)
HResultSet<HRecord>	executeQuery(String sql)
<T> HResultSet<T>	executeQuery(String sql, Class clazz)
List<HRecord>	executeQueryAndFetch(String sql)
<T> List<T>	executeQueryAndFetch(String sql, Class clazz)
ExecutionResults	executeUpdate(String sql)
Set<HMapping>	getAllMappings()
String	getAsyncExecutorName()
org.apache.hadoop.conf.Configuration	getConfiguration()
Set<String>	getFamilyNames(String tableName)
org.apache.hadoop.hbase.HTableDescriptor	getHTableDescriptor(String tableName)
HMapping	getMapping(String mappingName)
String	getQueryExecutorPoolName()
Set<String>	getTableNames()
boolean	indexExistsForMapping(String indexName, String mappingName)
boolean	indexExistsForTable(String indexName, String tableName)
boolean	isClosed()
boolean	isPooled()
boolean	mappingExists(String mappingName)
<T> HBatch<T>	newHBatch()
HPreparedStatement	prepareStatement(String str)
void	setAsyncExecutorName(String name)
void	setQueryExecutorPoolName(String name)
boolean	tableEnabled(String tableName)
boolean	tableExists(String tableName)

Method Detail

getConfiguration

org.apache.hadoop.conf.Configuration getConfiguration()

getFamilyNames

Set<String> getFamilyNames(String tableName)
                           throws HBqlException

Throws:

HBqlException

close

void close()

isClosed

boolean isClosed()
                 throws HBqlException

Throws:

HBqlException

isPooled

boolean isPooled()

tableExists

boolean tableExists(String tableName)
                    throws HBqlException

Throws:

HBqlException

getHTableDescriptor

org.apache.hadoop.hbase.HTableDescriptor getHTableDescriptor(String tableName)
                                                             throws HBqlException

Throws:

HBqlException

tableEnabled

boolean tableEnabled(String tableName)
                     throws HBqlException

Throws:

HBqlException

dropTable

void dropTable(String tableName)
               throws HBqlException

Throws:

HBqlException

disableTable

void disableTable(String tableName)
                  throws HBqlException

Throws:

HBqlException

enableTable

void enableTable(String tableName)
                 throws HBqlException

Throws:

HBqlException

getTableNames

Set<String> getTableNames()
                          throws HBqlException

Throws:

HBqlException

indexExistsForMapping

boolean indexExistsForMapping(String indexName,
                              String mappingName)
                              throws HBqlException

Throws:

HBqlException

dropIndexForMapping

void dropIndexForMapping(String indexName,
                         String mappingName)
                         throws HBqlException

Throws:

HBqlException

indexExistsForTable

boolean indexExistsForTable(String indexName,
                            String tableName)
                            throws HBqlException

Throws:

HBqlException

dropIndexForTable

void dropIndexForTable(String tableName,
                       String indexName)
                       throws HBqlException

Throws:

HBqlException

createStatement

HStatement createStatement()
                           throws HBqlException

Throws:

HBqlException

prepareStatement

HPreparedStatement prepareStatement(String str)
                                    throws HBqlException

Throws:

HBqlException

execute

ExecutionResults execute(String sql)
                         throws HBqlException

Throws:

HBqlException

executeQuery

HResultSet<HRecord> executeQuery(String sql)
                                 throws HBqlException

Throws:

HBqlException

executeQuery

<T> HResultSet<T> executeQuery(String sql,
                               Class clazz)
                           throws HBqlException

Throws:

HBqlException

executeQueryAndFetch

List<HRecord> executeQueryAndFetch(String sql)
                                   throws HBqlException

Throws:

HBqlException

executeQueryAndFetch

<T> List<T> executeQueryAndFetch(String sql,
                                 Class clazz)
                             throws HBqlException

Throws:

HBqlException

executeUpdate

ExecutionResults executeUpdate(String sql)
                               throws HBqlException

Throws:

HBqlException

getMapping

HMapping getMapping(String mappingName)
                    throws HBqlException

Throws:

HBqlException

mappingExists

boolean mappingExists(String mappingName)
                      throws HBqlException

Throws:

HBqlException

dropMapping

boolean dropMapping(String mappingName)
                    throws HBqlException

Throws:

HBqlException

getAllMappings

Set<HMapping> getAllMappings()
                             throws HBqlException

Throws:

HBqlException

setQueryExecutorPoolName

void setQueryExecutorPoolName(String name)

getQueryExecutorPoolName

String getQueryExecutorPoolName()

setAsyncExecutorName

void setAsyncExecutorName(String name)

getAsyncExecutorName

String getAsyncExecutorName()

newHBatch

<T> HBatch<T> newHBatch()