org.apache.hugegraph.backend.store.hbase

Class HbaseSessions

java.lang.Object

org.apache.hugegraph.backend.store.BackendSessionPool

org.apache.hugegraph.backend.store.hbase.HbaseSessions

public class HbaseSessions
extends BackendSessionPool

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	HbaseSessions.CountSession
static interface	HbaseSessions.HbaseSession<R> Session interface for HBase
protected static class	HbaseSessions.RowIterator
class	HbaseSessions.Session Session implement for HBase

Constructor Summary

Constructors

Constructor and Description
HbaseSessions(HugeConfig config, String namespace, String store)

Method Summary

Modifier and Type	Method and Description
void	compactTables(List<String> tableNames)
void	createNamespace()
void	createPreSplitTable(String table, List<byte[]> cfs, short numOfPartitions)
void	createTable(String table, List<byte[]> cfs)
Future<Void>	disableTableAsync(String table)
protected void	doClose()
void	dropNamespace()
void	dropTable(String table)
void	enableTable(String table)
boolean	existsNamespace()
boolean	existsTable(String table)
protected org.apache.hadoop.hbase.client.Connection	hbase()
protected HbaseSessions.Session	newSession()
void	open()
protected boolean	opened()
HbaseSessions.Session	session()
long	storeSize(String table)
Future<Void>	truncateTableAsync(String table)

Methods inherited from class org.apache.hugegraph.backend.store.BackendSessionPool

close, closed, config, forceResetSessions, getOrNewSession, toString, useSession

Methods inherited from class java.lang.Object

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

Constructor Detail

HbaseSessions

public HbaseSessions(HugeConfig config,
                     String namespace,
                     String store)

Method Detail

hbase

protected org.apache.hadoop.hbase.client.Connection hbase()

open

public void open()
          throws IOException

Specified by:

open in class BackendSessionPool

Throws:

IOException

opened

protected boolean opened()

Specified by:

opened in class BackendSessionPool

session

public final HbaseSessions.Session session()

Specified by:

session in class BackendSessionPool

newSession

protected HbaseSessions.Session newSession()

Specified by:

newSession in class BackendSessionPool

doClose

protected void doClose()

Specified by:

doClose in class BackendSessionPool

existsNamespace

public boolean existsNamespace()
                        throws IOException

Throws:

IOException

createNamespace

public void createNamespace()
                     throws IOException

Throws:

IOException

dropNamespace

public void dropNamespace()
                   throws IOException

Throws:

IOException

existsTable

public boolean existsTable(String table)
                    throws IOException

Throws:

IOException

createTable

public void createTable(String table,
                        List<byte[]> cfs)
                 throws IOException

Throws:

IOException

createPreSplitTable

public void createPreSplitTable(String table,
                                List<byte[]> cfs,
                                short numOfPartitions)
                         throws IOException

Throws:

IOException

dropTable

public void dropTable(String table)
               throws IOException

Throws:

IOException

enableTable

public void enableTable(String table)
                 throws IOException

Throws:

IOException

disableTableAsync

public Future<Void> disableTableAsync(String table)
                               throws IOException

Throws:

IOException

truncateTableAsync

public Future<Void> truncateTableAsync(String table)
                                throws IOException

Throws:

IOException

compactTables

public void compactTables(List<String> tableNames)
                   throws IOException

Throws:

IOException

storeSize

public long storeSize(String table)
               throws IOException

Throws:

IOException