org.wso2.carbon.analytics.datasource.hbase.rg

Class HBaseRegionSplitRecordGroup

java.lang.Object

org.wso2.carbon.analytics.datasource.hbase.rg.HBaseRegionSplitRecordGroup

All Implemented Interfaces:

Serializable, org.wso2.carbon.analytics.datasource.commons.RecordGroup

public class HBaseRegionSplitRecordGroup
extends Object
implements org.wso2.carbon.analytics.datasource.commons.RecordGroup

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HBaseRegionSplitRecordGroup()
HBaseRegionSplitRecordGroup(int tenantId, String tableName, List<String> columns, int recordsCount, byte[] startRow, byte[] endRow, String location)

Method Summary

Modifier and Type	Method and Description
List<String>	getColumns()
byte[]	getEndRow()
String[]	getLocations()
int	getRecordsCount()
byte[]	getStartRow()
String	getTableName()
int	getTenantId()

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseRegionSplitRecordGroup

public HBaseRegionSplitRecordGroup()

HBaseRegionSplitRecordGroup

public HBaseRegionSplitRecordGroup(int tenantId,
                                   String tableName,
                                   List<String> columns,
                                   int recordsCount,
                                   byte[] startRow,
                                   byte[] endRow,
                                   String location)

Method Detail

getLocations

public String[] getLocations()
                      throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

getLocations in interface org.wso2.carbon.analytics.datasource.commons.RecordGroup

Throws:

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

getTenantId

public int getTenantId()

getTableName

public String getTableName()

getColumns

public List<String> getColumns()

getStartRow

public byte[] getStartRow()

getEndRow

public byte[] getEndRow()

getRecordsCount

public int getRecordsCount()