org.wso2.carbon.analytics.datasource.hbase

Class HBaseAnalyticsRecordStore

java.lang.Object

org.wso2.carbon.analytics.datasource.hbase.HBaseAnalyticsRecordStore

All Implemented Interfaces:

org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

public class HBaseAnalyticsRecordStore
extends Object
implements org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Apache HBase implementation of AnalyticsRecordStore

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HBaseAnalyticsRecordStore.HBaseUnsupportedOperationException

Constructor Summary

Constructors

Constructor and Description
HBaseAnalyticsRecordStore()
HBaseAnalyticsRecordStore(org.apache.hadoop.hbase.client.Connection conn, HBaseAnalyticsConfigurationEntry entry)

Method Summary

Methods

Modifier and Type	Method and Description
void	createTable(int tenantId, String tableName)
void	delete(int tenantId, String tableName, List<String> ids)
void	delete(int tenantId, String tableName, long timeFrom, long timeTo)
void	deleteTable(int tenantId, String tableName)
void	destroy()
org.wso2.carbon.analytics.datasource.commons.RecordGroup[]	get(int tenantId, String tableName, int numPartitionsHint, List<String> columns, List<String> ids)
org.wso2.carbon.analytics.datasource.commons.RecordGroup[]	get(int tenantId, String tableName, int numPartitionsHint, List<String> columns, long timeFrom, long timeTo, int recordsFrom, int recordsCount)
long	getRecordCount(int tenantId, String tableName, long timeFrom, long timeTo)
org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>	getRecords(int tenantId, String tableName, List<String> columns, int recordsCount, byte[] startRow, byte[] endRow)
org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>	getRecords(int tenantId, String tableName, List<String> columns, List<String> ids)
org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>	getRecords(int tenantId, String tableName, List<String> columns, long startTime, long endTime, int recordsCount)
void	init(Map<String,String> properties)
boolean	isPaginationSupported()
boolean	isRecordCountSupported()
void	put(List<org.wso2.carbon.analytics.datasource.commons.Record> records)
org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>	readRecords(org.wso2.carbon.analytics.datasource.commons.RecordGroup recordGroup)
boolean	tableExists(int tenantId, String tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseAnalyticsRecordStore

public HBaseAnalyticsRecordStore(org.apache.hadoop.hbase.client.Connection conn,
                         HBaseAnalyticsConfigurationEntry entry)
                          throws IOException,
                                 org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

IOException

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

HBaseAnalyticsRecordStore

public HBaseAnalyticsRecordStore()

Method Detail

init

public void init(Map<String,String> properties)
          throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

init in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

createTable

public void createTable(int tenantId,
               String tableName)
                 throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

createTable in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

tableExists

public boolean tableExists(int tenantId,
                  String tableName)
                    throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

deleteTable

public void deleteTable(int tenantId,
               String tableName)
                 throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

deleteTable in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

isPaginationSupported

public boolean isPaginationSupported()

Specified by:

isPaginationSupported in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

isRecordCountSupported

public boolean isRecordCountSupported()

Specified by:

isRecordCountSupported in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

getRecordCount

public long getRecordCount(int tenantId,
                  String tableName,
                  long timeFrom,
                  long timeTo)
                    throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

getRecordCount in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

put

public void put(List<org.wso2.carbon.analytics.datasource.commons.Record> records)
         throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Specified by:

put in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

get

public org.wso2.carbon.analytics.datasource.commons.RecordGroup[] get(int tenantId,
                                                             String tableName,
                                                             int numPartitionsHint,
                                                             List<String> columns,
                                                             long timeFrom,
                                                             long timeTo,
                                                             int recordsFrom,
                                                             int recordsCount)
                                                               throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                                                                      org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Specified by:

get in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

get

public org.wso2.carbon.analytics.datasource.commons.RecordGroup[] get(int tenantId,
                                                             String tableName,
                                                             int numPartitionsHint,
                                                             List<String> columns,
                                                             List<String> ids)
                                                               throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                                                                      org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Specified by:

get in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

readRecords

public org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> readRecords(org.wso2.carbon.analytics.datasource.commons.RecordGroup recordGroup)
                                                                                                                                throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                                                                                                                                       org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Specified by:

readRecords in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

getRecords

public org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> getRecords(int tenantId,
                                                                                                                             String tableName,
                                                                                                                             List<String> columns,
                                                                                                                             List<String> ids)
                                                                                                                               throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                                                                                                                                      org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

getRecords

public org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> getRecords(int tenantId,
                                                                                                                             String tableName,
                                                                                                                             List<String> columns,
                                                                                                                             long startTime,
                                                                                                                             long endTime,
                                                                                                                             int recordsCount)
                                                                                                                               throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                                                                                                                                      org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

getRecords

public org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> getRecords(int tenantId,
                                                                                                                             String tableName,
                                                                                                                             List<String> columns,
                                                                                                                             int recordsCount,
                                                                                                                             byte[] startRow,
                                                                                                                             byte[] endRow)
                                                                                                                               throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                                                                                                                                      org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

delete

public void delete(int tenantId,
          String tableName,
          long timeFrom,
          long timeTo)
            throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

delete in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

delete

public void delete(int tenantId,
          String tableName,
          List<String> ids)
            throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

delete in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

destroy

public void destroy()
             throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

destroy in interface org.wso2.carbon.analytics.datasource.core.rs.AnalyticsRecordStore

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException