org.wso2.carbon.analytics.datasource.mongo

Class MongoAnalyticsRecordStore

java.lang.Object

org.wso2.carbon.analytics.datasource.mongo.MongoAnalyticsRecordStore

All Implemented Interfaces:

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

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

This class represents the Mongo implementation of AnalyticsRecordStore.

Constructor Summary

Constructors

Constructor and Description
MongoAnalyticsRecordStore()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoAnalyticsRecordStore

public MongoAnalyticsRecordStore()

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

delete

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

Specified by:

delete 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

delete

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

Specified by:

delete 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

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

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

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

Specified by:

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

Throws:

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

getRecordCount

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

Specified by:

getRecordCount 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

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

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