org.wso2.carbon.analytics.api

Class CarbonAnalyticsAPI

java.lang.Object

org.wso2.carbon.analytics.api.CarbonAnalyticsAPI

All Implemented Interfaces:

AnalyticsDataAPI, org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService, org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

public class CarbonAnalyticsAPI
extends Object
implements AnalyticsDataAPI

This is the actual implementation of the AnalyticsDataAPI osgi service exposed.

Constructor Summary

Constructors

Constructor and Description
CarbonAnalyticsAPI()
CarbonAnalyticsAPI(String configFilePath)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearIndexData(int tenantId, String tableName)
void	clearIndexData(String username, String tableName)
void	createTable(int tenantId, String tableName)
void	createTable(int tenantId, String recordStoreName, String tableName)
void	createTable(String username, String tableName)
void	createTable(String username, String recordStoreName, String tableName)
void	createTableIfNotExists(int tenantId, String recordStoreName, String tableName)
void	createTableIfNotExists(String username, String recordStoreName, String tableName)
void	delete(int tenantId, String tableName, List<String> ids)
void	delete(int tenantId, String tableName, long timeFrom, long timeTo)
void	delete(String username, String tableName, List<String> ids)
void	delete(String username, String tableName, long timeFrom, long timeTo)
void	deleteTable(int tenantId, String tableName)
void	deleteTable(String username, String tableName)
void	destroy()
org.wso2.carbon.analytics.dataservice.commons.SubCategories	drillDownCategories(int tenantId, org.wso2.carbon.analytics.dataservice.commons.CategoryDrillDownRequest drillDownRequest)
org.wso2.carbon.analytics.dataservice.commons.SubCategories	drillDownCategories(String username, org.wso2.carbon.analytics.dataservice.commons.CategoryDrillDownRequest drillDownRequest)
List<org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRange>	drillDownRangeCount(int tenantId, org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
List<org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRange>	drillDownRangeCount(String username, org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry>	drillDownSearch(int tenantId, org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry>	drillDownSearch(String username, org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
double	drillDownSearchCount(int tenantId, org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
double	drillDownSearchCount(String username, org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse	get(int tenantId, String tableName, int numPartitionsHint, List<String> columns, List<String> ids)
org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse	get(int tenantId, String tableName, int numPartitionsHint, List<String> columns, long timeFrom, long timeTo, int recordsFrom, int recordsCount)
org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse	get(String username, String tableName, int numPartitionsHint, List<String> columns, List<String> ids)
org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse	get(String username, 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)
long	getRecordCount(String username, String tableName, long timeFrom, long timeTo)
String	getRecordStoreNameByTable(int tenantId, String tableName)
String	getRecordStoreNameByTable(String username, String tableName)
org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema	getTableSchema(int tenantId, String tableName)
org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema	getTableSchema(String username, String tableName)
org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse	getWithKeyValues(int tenantId, String tableName, int numPartitionsHint, List<String> columns, List<Map<String,Object>> valuesBatch)
org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse	getWithKeyValues(String username, String tableName, int numPartitionsHint, List<String> columns, List<Map<String,Object>> valuesBatch)
boolean	isPaginationSupported(String recordStoreName)
boolean	isRecordCountSupported(String recordStoreName)
List<String>	listRecordStoreNames()
List<String>	listTables(int tenantId)
List<String>	listTables(String username)
void	put(List<org.wso2.carbon.analytics.datasource.commons.Record> records)
void	put(String username, List<org.wso2.carbon.analytics.datasource.commons.Record> records)
org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>	readRecords(String recordStoreName, org.wso2.carbon.analytics.datasource.commons.RecordGroup recordGroup)
void	reIndex(int tenantId, String tableName, long startTime, long endTime)
void	reIndex(String username, String tableName, long startTime, long endTime)
List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry>	search(int tenantId, String tableName, String query, int start, int count)
List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry>	search(int tenantId, String tableName, String query, int start, int count, List<org.wso2.carbon.analytics.dataservice.commons.SortByField> sortByFields)
List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry>	search(String username, String tableName, String query, int start, int count)
List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry>	search(String username, String tableName, String query, int start, int count, List<org.wso2.carbon.analytics.dataservice.commons.SortByField> sortByFields)
int	searchCount(int tenantId, String tableName, String query)
int	searchCount(String username, String tableName, String query)
org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>	searchWithAggregates(int tenantId, org.wso2.carbon.analytics.dataservice.commons.AggregateRequest aggregateRequest)
List<org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>>	searchWithAggregates(int tenantId, org.wso2.carbon.analytics.dataservice.commons.AggregateRequest[] aggregateRequests)
org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>	searchWithAggregates(String username, org.wso2.carbon.analytics.dataservice.commons.AggregateRequest aggregateRequest)
List<org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>>	searchWithAggregates(String username, org.wso2.carbon.analytics.dataservice.commons.AggregateRequest[] aggregateRequests)
void	setTableSchema(int tenantId, String tableName, org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema schema)
void	setTableSchema(String username, String tableName, org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema schema)
boolean	tableExists(int tenantId, String tableName)
boolean	tableExists(String username, String tableName)
void	waitForIndexing(int tenantId, String tableName, long maxWait)
void	waitForIndexing(long maxWait)
void	waitForIndexing(String username, String tableName, long maxWait)

Methods inherited from class java.lang.Object

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

Constructor Detail

CarbonAnalyticsAPI

public CarbonAnalyticsAPI(String configFilePath)

CarbonAnalyticsAPI

public CarbonAnalyticsAPI()

Method Detail

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.dataservice.core.AnalyticsDataService

Throws:

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

createTable

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

Specified by:

createTable in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

createTableIfNotExists

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

Specified by:

createTableIfNotExists in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

clearIndexData

public void clearIndexData(int tenantId,
                  String tableName)
                    throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

clearIndexData in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

setTableSchema

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

Specified by:

setTableSchema in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

getTableSchema

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

Specified by:

getTableSchema in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

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

Specified by:

tableExists in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

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.dataservice.core.AnalyticsDataService

Throws:

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

listTables

public List<String> listTables(int tenantId)
                        throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

listTables in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

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

Specified by:

getRecordCount in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

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

Specified by:

put in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

get

public org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse 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

Specified by:

get in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

get

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

Specified by:

get in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

createTable

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

Specified by:

createTable in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

createTable

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

Specified by:

createTable in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

createTableIfNotExists

public void createTableIfNotExists(String username,
                          String recordStoreName,
                          String tableName)
                            throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

createTableIfNotExists in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

clearIndexData

public void clearIndexData(String username,
                  String tableName)
                    throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

clearIndexData in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

setTableSchema

public void setTableSchema(String username,
                  String tableName,
                  org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema schema)
                    throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

setTableSchema in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

getTableSchema

public org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema getTableSchema(String username,
                                                                          String tableName)
                                                                            throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException,
                                                                                   org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

getTableSchema in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

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

tableExists

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

Specified by:

tableExists in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

deleteTable

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

Specified by:

deleteTable in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

listTables

public List<String> listTables(String username)
                        throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

listTables in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

getRecordCount

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

Specified by:

getRecordCount in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

put

public void put(String username,
       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.dataservice.core.SecureAnalyticsDataService

Throws:

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

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

get

public org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse get(String username,
                                                                      String tableName,
                                                                      int numPartitionsHint,
                                                                      List<String> columns,
                                                                      long timeFrom,
                                                                      long timeTo,
                                                                      int recordsFrom,
                                                                      int recordsCount)
                                                                        throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

get in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

get

public org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse get(String username,
                                                                      String tableName,
                                                                      int numPartitionsHint,
                                                                      List<String> columns,
                                                                      List<String> ids)
                                                                        throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

get in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

getWithKeyValues

public org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse getWithKeyValues(String username,
                                                                                   String tableName,
                                                                                   int numPartitionsHint,
                                                                                   List<String> columns,
                                                                                   List<Map<String,Object>> valuesBatch)
                                                                                     throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                                                                                            org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Specified by:

getWithKeyValues in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

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

isPaginationSupported

public boolean isPaginationSupported(String recordStoreName)
                              throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

isPaginationSupported in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Specified by:

isPaginationSupported in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

isRecordCountSupported

public boolean isRecordCountSupported(String recordStoreName)
                               throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

isRecordCountSupported in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Specified by:

isRecordCountSupported in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

delete

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

Specified by:

delete in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

delete

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

Specified by:

delete in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

search

public List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> search(String username,
                                                                           String tableName,
                                                                           String query,
                                                                           int start,
                                                                           int count,
                                                                           List<org.wso2.carbon.analytics.dataservice.commons.SortByField> sortByFields)
                                                                             throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException,
                                                                                    org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

search in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

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

search

public List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> search(String username,
                                                                           String tableName,
                                                                           String query,
                                                                           int start,
                                                                           int count)
                                                                             throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

search in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

searchCount

public int searchCount(String username,
              String tableName,
              String query)
                throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

searchCount in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

drillDownSearch

public List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> drillDownSearch(String username,
                                                                                    org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
                                                                                      throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

drillDownSearch in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

drillDownSearchCount

public double drillDownSearchCount(String username,
                          org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
                            throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

drillDownSearchCount in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

drillDownCategories

public org.wso2.carbon.analytics.dataservice.commons.SubCategories drillDownCategories(String username,
                                                                              org.wso2.carbon.analytics.dataservice.commons.CategoryDrillDownRequest drillDownRequest)
                                                                                throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

drillDownCategories in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

drillDownRangeCount

public List<org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRange> drillDownRangeCount(String username,
                                                                                              org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
                                                                                                throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

drillDownRangeCount in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

searchWithAggregates

public org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> searchWithAggregates(String username,
                                                                                                                                       org.wso2.carbon.analytics.dataservice.commons.AggregateRequest aggregateRequest)
                                                                                                                                         throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

searchWithAggregates in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

searchWithAggregates

public List<org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>> searchWithAggregates(String username,
                                                                                                                                             org.wso2.carbon.analytics.dataservice.commons.AggregateRequest[] aggregateRequests)
                                                                                                                                               throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

searchWithAggregates in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

reIndex

public void reIndex(String username,
           String tableName,
           long startTime,
           long endTime)
             throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

reIndex in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

readRecords

public org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> readRecords(String recordStoreName,
                                                                                                                              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.dataservice.core.AnalyticsDataService

Specified by:

readRecords in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

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

Specified by:

delete in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

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.dataservice.core.AnalyticsDataService

Throws:

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

search

public List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> search(int tenantId,
                                                                           String tableName,
                                                                           String query,
                                                                           int start,
                                                                           int count)
                                                                             throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

search in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

search

public List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> search(int tenantId,
                                                                           String tableName,
                                                                           String query,
                                                                           int start,
                                                                           int count,
                                                                           List<org.wso2.carbon.analytics.dataservice.commons.SortByField> sortByFields)
                                                                             throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

search in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

searchCount

public int searchCount(int tenantId,
              String tableName,
              String query)
                throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

searchCount in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

drillDownSearch

public List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> drillDownSearch(int tenantId,
                                                                                    org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
                                                                                      throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

drillDownSearch in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

drillDownSearchCount

public double drillDownSearchCount(int tenantId,
                          org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
                            throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

drillDownSearchCount in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

drillDownCategories

public org.wso2.carbon.analytics.dataservice.commons.SubCategories drillDownCategories(int tenantId,
                                                                              org.wso2.carbon.analytics.dataservice.commons.CategoryDrillDownRequest drillDownRequest)
                                                                                throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

drillDownCategories in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

drillDownRangeCount

public List<org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRange> drillDownRangeCount(int tenantId,
                                                                                              org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
                                                                                                throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

Specified by:

drillDownRangeCount in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException

searchWithAggregates

public org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> searchWithAggregates(int tenantId,
                                                                                                                                       org.wso2.carbon.analytics.dataservice.commons.AggregateRequest aggregateRequest)
                                                                                                                                         throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

searchWithAggregates in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

searchWithAggregates

public List<org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>> searchWithAggregates(int tenantId,
                                                                                                                                             org.wso2.carbon.analytics.dataservice.commons.AggregateRequest[] aggregateRequests)
                                                                                                                                               throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

searchWithAggregates in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

reIndex

public void reIndex(int tenantId,
           String tableName,
           long startTime,
           long endTime)
             throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

reIndex in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

waitForIndexing

public void waitForIndexing(long maxWait)
                     throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

waitForIndexing in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Specified by:

waitForIndexing in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

waitForIndexing

public void waitForIndexing(String username,
                   String tableName,
                   long maxWait)
                     throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTimeoutException,
                            org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Specified by:

waitForIndexing in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

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

waitForIndexing

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

Specified by:

waitForIndexing in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

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.dataservice.core.AnalyticsDataService

Specified by:

destroy in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

getWithKeyValues

public org.wso2.carbon.analytics.dataservice.commons.AnalyticsDataResponse getWithKeyValues(int tenantId,
                                                                                   String tableName,
                                                                                   int numPartitionsHint,
                                                                                   List<String> columns,
                                                                                   List<Map<String,Object>> valuesBatch)
                                                                                     throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                                                                                            org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Specified by:

getWithKeyValues in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

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

getRecordStoreNameByTable

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

Specified by:

getRecordStoreNameByTable in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Throws:

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

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

listRecordStoreNames

public List<String> listRecordStoreNames()

Specified by:

listRecordStoreNames in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataService

Specified by:

listRecordStoreNames in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

getRecordStoreNameByTable

public String getRecordStoreNameByTable(String username,
                               String tableName)
                                 throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException,
                                        org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException

Specified by:

getRecordStoreNameByTable in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataService

Throws:

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

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