public class CarbonAnalyticsAPI extends Object implements AnalyticsDataAPI
| Constructor and Description |
|---|
CarbonAnalyticsAPI() |
CarbonAnalyticsAPI(String configFilePath) |
| 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) |
public CarbonAnalyticsAPI(String configFilePath)
public CarbonAnalyticsAPI()
public void createTable(int tenantId,
String tableName)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
createTable in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void createTable(int tenantId,
String recordStoreName,
String tableName)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
createTable in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void createTableIfNotExists(int tenantId,
String recordStoreName,
String tableName)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
createTableIfNotExists in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void clearIndexData(int tenantId,
String tableName)
throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException
clearIndexData in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic void setTableSchema(int tenantId,
String tableName,
org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema schema)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
setTableSchema in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema getTableSchema(int tenantId,
String tableName)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
getTableSchema in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic boolean tableExists(int tenantId,
String tableName)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
tableExists in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void deleteTable(int tenantId,
String tableName)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
deleteTable in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic List<String> listTables(int tenantId) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
listTables in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic long getRecordCount(int tenantId,
String tableName,
long timeFrom,
long timeTo)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
getRecordCount in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void put(List<org.wso2.carbon.analytics.datasource.commons.Record> records) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
put in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
get in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
get in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void createTable(String username, String tableName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
createTable in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void createTable(String username, String recordStoreName, String tableName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
createTable in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void createTableIfNotExists(String username, String recordStoreName, String tableName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
createTableIfNotExists in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void clearIndexData(String username, String tableName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
clearIndexData in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void setTableSchema(String username, String tableName, org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema schema) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
setTableSchema in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
getTableSchema in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableExceptionorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic boolean tableExists(String username, String tableName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
tableExists in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void deleteTable(String username, String tableName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
deleteTable in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic List<String> listTables(String username) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
listTables in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic long getRecordCount(String username, String tableName, long timeFrom, long timeTo) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
getRecordCount in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
put in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableExceptionpublic 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
get in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
get in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
getWithKeyValues in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableExceptionpublic boolean isPaginationSupported(String recordStoreName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
isPaginationSupported in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceisPaginationSupported in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic boolean isRecordCountSupported(String recordStoreName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
isRecordCountSupported in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceisRecordCountSupported in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void delete(String username, String tableName, long timeFrom, long timeTo) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
delete in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void delete(String username, String tableName, List<String> ids) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
delete in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
search in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
search in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic int searchCount(String username, String tableName, String query) throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException
searchCount in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic 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
drillDownSearch in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic double drillDownSearchCount(String username, org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest) throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException
drillDownSearchCount in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic 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
drillDownCategories in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic 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
drillDownRangeCount in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic 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
searchWithAggregates in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
searchWithAggregates in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void reIndex(String username, String tableName, long startTime, long endTime) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
reIndex in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
readRecords in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServicereadRecords in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void delete(int tenantId,
String tableName,
long timeFrom,
long timeTo)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
delete in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void delete(int tenantId,
String tableName,
List<String> ids)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
delete in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
search in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
search in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic int searchCount(int tenantId,
String tableName,
String query)
throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException
searchCount in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic 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
drillDownSearch in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic double drillDownSearchCount(int tenantId,
org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest drillDownRequest)
throws org.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexException
drillDownSearchCount in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic 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
drillDownCategories in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic 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
drillDownRangeCount in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.dataservice.commons.exception.AnalyticsIndexExceptionpublic 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
searchWithAggregates in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
searchWithAggregates in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void reIndex(int tenantId,
String tableName,
long startTime,
long endTime)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
reIndex in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void waitForIndexing(long maxWait)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
waitForIndexing in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServicewaitForIndexing in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
waitForIndexing in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTimeoutExceptionorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void waitForIndexing(int tenantId,
String tableName,
long maxWait)
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
waitForIndexing in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic void destroy()
throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException
destroy in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServicedestroy in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionpublic 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
getWithKeyValues in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableExceptionpublic String getRecordStoreNameByTable(int tenantId, String tableName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException, org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException
getRecordStoreNameByTable in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableExceptionpublic List<String> listRecordStoreNames()
listRecordStoreNames in interface org.wso2.carbon.analytics.dataservice.core.AnalyticsDataServicelistRecordStoreNames in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServicepublic String getRecordStoreNameByTable(String username, String tableName) throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException, org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableException
getRecordStoreNameByTable in interface org.wso2.carbon.analytics.dataservice.core.SecureAnalyticsDataServiceorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsExceptionorg.wso2.carbon.analytics.datasource.commons.exception.AnalyticsTableNotAvailableExceptionCopyright © 2016 WSO2. All rights reserved.