org.wso2.carbon.analytics.datasource.mongo

Class GlobalMongoRecordGroup

java.lang.Object

org.wso2.carbon.analytics.datasource.mongo.GlobalMongoRecordGroup

All Implemented Interfaces:

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

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

We are going to leave partitioning to Mongo sharded cluster, and to mongos the decision of where to query. Implementation copied from Cassandra.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GlobalMongoRecordGroup(int tenantId, String tableName, List<String> columns, List<String> ids)
GlobalMongoRecordGroup(int tenantId, String tableName, List<String> columns, long timeFrom, long timeTo, int count)

Method Summary

Modifier and Type	Method and Description
List<String>	getColumns()
int	getCount()
List<String>	getIds()
String[]	getLocations()
String	getTableName()
int	getTenantId()
long	getTimeFrom()
long	getTimeTo()
boolean	isByIds()

Methods inherited from class java.lang.Object

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

Constructor Detail

GlobalMongoRecordGroup

public GlobalMongoRecordGroup(int tenantId,
                              String tableName,
                              List<String> columns,
                              long timeFrom,
                              long timeTo,
                              int count)

GlobalMongoRecordGroup

public GlobalMongoRecordGroup(int tenantId,
                              String tableName,
                              List<String> columns,
                              List<String> ids)

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

isByIds

public boolean isByIds()

getTenantId

public int getTenantId()

getTableName

public String getTableName()

getColumns

public List<String> getColumns()

getTimeFrom

public long getTimeFrom()

getTimeTo

public long getTimeTo()

getIds

public List<String> getIds()

getCount

public int getCount()