org.apache.hugegraph.backend.store.hbase

Class HbaseSessions.Session

java.lang.Object

org.apache.hugegraph.backend.store.BackendSession.AbstractBackendSession

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

All Implemented Interfaces:

BackendSession, HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

Enclosing class:

HbaseSessions

public class HbaseSessions.Session
extends BackendSession.AbstractBackendSession
implements HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

Session implement for HBase

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hugegraph.backend.store.BackendSession

BackendSession.AbstractBackendSession

Field Summary

Fields inherited from class org.apache.hugegraph.backend.store.BackendSession.AbstractBackendSession

opened

Constructor Summary

Constructors

Constructor and Description
Session()

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	closed()
Integer	commit() Commit all updates(put/delete) to DB
HbaseSessions.CountSession	countSession()
void	delete(String table, byte[] family, byte[] rowkey) Delete a record by rowkey from a table
HbaseSessions.RowIterator	get(String table, byte[] family, byte[] rowkey) Get a record by rowkey from a table
HbaseSessions.RowIterator	get(String table, byte[] family, byte[] rowkey, byte[] qualifier) Get a record by rowkey and qualifier from a table
HbaseSessions.RowIterator	get(String table, byte[] family, Set<byte[]> rowkeys) Get multi records by rowkeys from a table
boolean	hasChanges() Any change in the session
org.apache.hadoop.hbase.client.Connection	hbase()
long	increase(String table, byte[] family, byte[] rowkey, byte[] qualifier, long value) Increase a counter by rowkey and qualifier to a table
String	namespace()
void	open()
void	put(String table, byte[] family, byte[] rowkey, byte[] qualifier, byte[] value) Add a row record to a table(can be used when adding an index)
void	put(String table, byte[] family, byte[] rowkey, byte[] qualifier, byte[] value, long ttl) Add a row record to a table with ttl for index
void	put(String table, byte[] family, byte[] rowkey, Collection<BackendEntry.BackendColumn> columns) Add a row record to a table
void	put(String table, byte[] family, byte[] rowkey, Collection<BackendEntry.BackendColumn> columns, long ttl) Add a row record to a table with ttl
void	remove(String table, byte[] family, byte[] rowkey, byte[] qualifier) Delete a record by rowkey and qualifier from a table
void	remove(String table, byte[] family, byte[] rowkey, byte[] qualifier, boolean latestVersion) Delete a record by rowkey and qualifier from a table, just delete the latest version of the specified column if need
void	rollback() Rollback all updates(put/delete) not committed
HbaseSessions.RowIterator	scan(String table, byte[] startRow, boolean inclusiveStart, byte[] stopRow, boolean inclusiveStop) Scan records by rowkey range from a table
HbaseSessions.RowIterator	scan(String table, org.apache.hadoop.hbase.client.Scan scan) Inner scan: send scan request to HBase and get iterator
long	storeSize(String table) Get store size of specified table

Methods inherited from class org.apache.hugegraph.backend.store.BackendSession.AbstractBackendSession

attach, closeable, created, detach, opened, txState, txState, update, updated

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hugegraph.backend.store.hbase.HbaseSessions.HbaseSession

scan, scan, scan, scan, scan

Methods inherited from interface org.apache.hugegraph.backend.store.BackendSession

reconnectIfNeeded, reset

Constructor Detail

Session

public Session()

Method Detail

hbase

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

namespace

public String namespace()

open

public void open()

Specified by:

open in interface BackendSession

close

public void close()

Specified by:

close in interface BackendSession

closed

public boolean closed()

Specified by:

closed in interface BackendSession

Overrides:

closed in class BackendSession.AbstractBackendSession

hasChanges

public boolean hasChanges()

Any change in the session

Specified by:

hasChanges in interface BackendSession

commit

public Integer commit()

Commit all updates(put/delete) to DB

Specified by:

commit in interface BackendSession

rollback

public void rollback()

Rollback all updates(put/delete) not committed

Specified by:

rollback in interface BackendSession

put

public void put(String table,
                byte[] family,
                byte[] rowkey,
                Collection<BackendEntry.BackendColumn> columns)

Add a row record to a table

Specified by:

put in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

put

public void put(String table,
                byte[] family,
                byte[] rowkey,
                Collection<BackendEntry.BackendColumn> columns,
                long ttl)

Add a row record to a table with ttl

put

public void put(String table,
                byte[] family,
                byte[] rowkey,
                byte[] qualifier,
                byte[] value)

Add a row record to a table(can be used when adding an index)

Specified by:

put in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

put

public void put(String table,
                byte[] family,
                byte[] rowkey,
                byte[] qualifier,
                byte[] value,
                long ttl)

Add a row record to a table with ttl for index

remove

public void remove(String table,
                   byte[] family,
                   byte[] rowkey,
                   byte[] qualifier)

Delete a record by rowkey and qualifier from a table

Specified by:

remove in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

remove

public void remove(String table,
                   byte[] family,
                   byte[] rowkey,
                   byte[] qualifier,
                   boolean latestVersion)

Delete a record by rowkey and qualifier from a table, just delete the latest version of the specified column if need

Specified by:

remove in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

delete

public void delete(String table,
                   byte[] family,
                   byte[] rowkey)

Delete a record by rowkey from a table

Specified by:

delete in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

get

public HbaseSessions.RowIterator get(String table,
                                     byte[] family,
                                     byte[] rowkey,
                                     byte[] qualifier)

Get a record by rowkey and qualifier from a table

Specified by:

get in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

get

public HbaseSessions.RowIterator get(String table,
                                     byte[] family,
                                     byte[] rowkey)

Get a record by rowkey from a table

Specified by:

get in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

get

public HbaseSessions.RowIterator get(String table,
                                     byte[] family,
                                     Set<byte[]> rowkeys)

Get multi records by rowkeys from a table

Specified by:

get in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

scan

public HbaseSessions.RowIterator scan(String table,
                                      byte[] startRow,
                                      boolean inclusiveStart,
                                      byte[] stopRow,
                                      boolean inclusiveStop)

Scan records by rowkey range from a table

Specified by:

scan in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

scan

public HbaseSessions.RowIterator scan(String table,
                                      org.apache.hadoop.hbase.client.Scan scan)

Inner scan: send scan request to HBase and get iterator

Specified by:

scan in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

increase

public long increase(String table,
                     byte[] family,
                     byte[] rowkey,
                     byte[] qualifier,
                     long value)

Increase a counter by rowkey and qualifier to a table

Specified by:

increase in interface HbaseSessions.HbaseSession<HbaseSessions.RowIterator>

storeSize

public long storeSize(String table)
               throws IOException

Get store size of specified table

Throws:

IOException

countSession

public HbaseSessions.CountSession countSession()