org.wso2.carbon.analytics.datasource.cassandra

Class TokenRangeRecordGroup

java.lang.Object

org.wso2.carbon.analytics.datasource.cassandra.TokenRangeRecordGroup

All Implemented Interfaces:

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

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

Cassandra RecordGroup implementation, which is token range aware, used for partition based record groups.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TokenRangeRecordGroup(int tenantId, String tableName, List<String> columns, List<CassandraTokenRange> tokenRanges, String host, int count)

Method Summary

Modifier and Type	Method and Description
List<String>	getColumns()
int	getCount()
String[]	getLocations()
String	getTableName()
int	getTenantId()
List<CassandraTokenRange>	getTokenRanges()

Methods inherited from class java.lang.Object

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

Constructor Detail

TokenRangeRecordGroup

public TokenRangeRecordGroup(int tenantId,
                             String tableName,
                             List<String> columns,
                             List<CassandraTokenRange> tokenRanges,
                             String host,
                             int count)

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()

getTokenRanges

public List<CassandraTokenRange> getTokenRanges()

getCount

public int getCount()