org.wso2.carbon.analytics.jsservice

Class AnalyticsJSServiceConnector

java.lang.Object

org.wso2.carbon.analytics.jsservice.AnalyticsJSServiceConnector

Direct Known Subclasses:

AnalyticsCachedJSServiceConnector

public class AnalyticsJSServiceConnector
extends Object

This class will contain all the analytics data service APIs which will be called from Analytics.jag.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AnalyticsJSServiceConnector.ResponseStatus The Enum ResponseStatus.

Constructor Summary

Constructors

Constructor and Description
AnalyticsJSServiceConnector()

Method Summary

Methods

Modifier and Type	Method and Description
ResponseBean	addStreamDefinition(int tenantId, String streamDefAsString)
ResponseBean	addStreamDefinition(String streamDefAsString)
ResponseBean	addStreamDefinition(String username, String streamDefAsString)
ResponseBean	clearIndexData(int tenantId, String tableName)
ResponseBean	clearIndexData(String username, String tableName)
ResponseBean	drillDownCategories(int tenantId, String tableName, String queryAsString)
ResponseBean	drillDownCategories(String username, String tableName, String queryAsString)
ResponseBean	drillDownRangeCount(int tenantId, String tableName, String queryAsString)
ResponseBean	drillDownRangeCount(String username, String tableName, String queryAsString)
ResponseBean	drillDownSearch(int tenantId, String tableName, String queryAsString)
ResponseBean	drillDownSearch(String username, String tableName, String queryAsString)
ResponseBean	drillDownSearchCount(int tenantId, String tableName, String queryAsString)
ResponseBean	drillDownSearchCount(String username, String tableName, String queryAsString)
ResponseBean	getRecordCount(int tenantId, String tableName)
ResponseBean	getRecordCount(String username, String tableName)
ResponseBean	getRecordsByIds(int tenantId, String tableName, String idsAsString)
ResponseBean	getRecordsByIds(String username, String tableName, String idsAsString)
ResponseBean	getRecordsByRange(int tenantId, String tableName, String timeFrom, String timeTo, String recordsFrom, String count, String columns)
ResponseBean	getRecordsByRange(String username, String tableName, String timeFrom, String timeTo, String recordsFrom, String count, String columns)
ResponseBean	getRecordStoreByTable(int tenantId, String tableName)
ResponseBean	getRecordStoreByTable(String username, String tableName)
ResponseBean	getRecordStoreList()
ResponseBean	getStreamDefinition(int tenantId, String requestAsString)
ResponseBean	getStreamDefinition(String requestAsString)
ResponseBean	getStreamDefinition(String username, String requestAsString)
ResponseBean	getTableList(int tenantId)
ResponseBean	getTableList(String username)
ResponseBean	getTableSchema(int tenantId, String tableName)
ResponseBean	getTableSchema(String username, String tableName)
ResponseBean	getWithKeyValues(int tenantId, String tableName, String valuesBatch)
ResponseBean	getWithKeyValues(String username, String tableName, String valuesBatch)
ResponseBean	handleResponse(AnalyticsJSServiceConnector.ResponseStatus responseStatus, String message)
ResponseBean	isPaginationSupported(String recordStoreName)
ResponseBean	publishEvent(int tenantId, String eventAsString)
ResponseBean	publishEvent(String eventAsString)
ResponseBean	publishEvent(String username, String eventAsString)
ResponseBean	reIndex(int tenantId, String tableName, String startTime, String endTime)
ResponseBean	reIndex(String username, String tableName, String startTime, String endTime)
ResponseBean	search(int tenantId, String tableName, String queryAsString)
ResponseBean	search(String username, String tableName, String queryAsString)
ResponseBean	searchCount(int tenantId, String tableName, String queryAsString)
ResponseBean	searchCount(String username, String tableName, String queryAsString)
ResponseBean	searchMultiTablesWithAggregates(int tenantId, String requestsAsString)
ResponseBean	searchMultiTablesWithAggregates(String username, String requestsAsString)
ResponseBean	searchWithAggregates(int tenantId, String tableName, String requestAsString)
ResponseBean	searchWithAggregates(String username, String tableName, String requestAsString)
String	setTableSchema(int tenantId, String tableName, String schemaAsString)
String	setTableSchema(String username, String tableName, String schemaAsString)
ResponseBean	tableExists(int tenantId, String tableName)
ResponseBean	tableExists(String username, String tableName)
ResponseBean	waitForIndexing(long seconds)
ResponseBean	waitForIndexingForTable(int tenantId, String tableName, long seconds)
ResponseBean	waitForIndexingForTable(String username, String tableName, long seconds)

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsJSServiceConnector

public AnalyticsJSServiceConnector()

Method Detail

tableExists

public ResponseBean tableExists(String username,
                       String tableName)

tableExists

public ResponseBean tableExists(int tenantId,
                       String tableName)

getStreamDefinition

public ResponseBean getStreamDefinition(String username,
                               String requestAsString)

getStreamDefinition

public ResponseBean getStreamDefinition(int tenantId,
                               String requestAsString)

getStreamDefinition

public ResponseBean getStreamDefinition(String requestAsString)

getTableList

public ResponseBean getTableList(String username)

getTableList

public ResponseBean getTableList(int tenantId)

getRecordStoreList

public ResponseBean getRecordStoreList()

getRecordStoreByTable

public ResponseBean getRecordStoreByTable(String username,
                                 String tableName)

getRecordStoreByTable

public ResponseBean getRecordStoreByTable(int tenantId,
                                 String tableName)

getRecordCount

public ResponseBean getRecordCount(String username,
                          String tableName)

getRecordCount

public ResponseBean getRecordCount(int tenantId,
                          String tableName)

getRecordsByRange

public ResponseBean getRecordsByRange(String username,
                             String tableName,
                             String timeFrom,
                             String timeTo,
                             String recordsFrom,
                             String count,
                             String columns)

getRecordsByRange

public ResponseBean getRecordsByRange(int tenantId,
                             String tableName,
                             String timeFrom,
                             String timeTo,
                             String recordsFrom,
                             String count,
                             String columns)

getWithKeyValues

public ResponseBean getWithKeyValues(String username,
                            String tableName,
                            String valuesBatch)

getWithKeyValues

public ResponseBean getWithKeyValues(int tenantId,
                            String tableName,
                            String valuesBatch)

getRecordsByIds

public ResponseBean getRecordsByIds(String username,
                           String tableName,
                           String idsAsString)

getRecordsByIds

public ResponseBean getRecordsByIds(int tenantId,
                           String tableName,
                           String idsAsString)

clearIndexData

public ResponseBean clearIndexData(String username,
                          String tableName)

clearIndexData

public ResponseBean clearIndexData(int tenantId,
                          String tableName)

search

public ResponseBean search(String username,
                  String tableName,
                  String queryAsString)

search

public ResponseBean search(int tenantId,
                  String tableName,
                  String queryAsString)

searchWithAggregates

public ResponseBean searchWithAggregates(String username,
                                String tableName,
                                String requestAsString)

searchWithAggregates

public ResponseBean searchWithAggregates(int tenantId,
                                String tableName,
                                String requestAsString)

searchMultiTablesWithAggregates

public ResponseBean searchMultiTablesWithAggregates(String username,
                                           String requestsAsString)

searchMultiTablesWithAggregates

public ResponseBean searchMultiTablesWithAggregates(int tenantId,
                                           String requestsAsString)

reIndex

public ResponseBean reIndex(String username,
                   String tableName,
                   String startTime,
                   String endTime)

reIndex

public ResponseBean reIndex(int tenantId,
                   String tableName,
                   String startTime,
                   String endTime)

searchCount

public ResponseBean searchCount(String username,
                       String tableName,
                       String queryAsString)

searchCount

public ResponseBean searchCount(int tenantId,
                       String tableName,
                       String queryAsString)

waitForIndexing

public ResponseBean waitForIndexing(long seconds)

waitForIndexingForTable

public ResponseBean waitForIndexingForTable(String username,
                                   String tableName,
                                   long seconds)

waitForIndexingForTable

public ResponseBean waitForIndexingForTable(int tenantId,
                                   String tableName,
                                   long seconds)

setTableSchema

public String setTableSchema(String username,
                    String tableName,
                    String schemaAsString)

setTableSchema

public String setTableSchema(int tenantId,
                    String tableName,
                    String schemaAsString)

getTableSchema

public ResponseBean getTableSchema(String username,
                          String tableName)

getTableSchema

public ResponseBean getTableSchema(int tenantId,
                          String tableName)

isPaginationSupported

public ResponseBean isPaginationSupported(String recordStoreName)

drillDownCategories

public ResponseBean drillDownCategories(String username,
                               String tableName,
                               String queryAsString)

drillDownCategories

public ResponseBean drillDownCategories(int tenantId,
                               String tableName,
                               String queryAsString)

drillDownSearch

public ResponseBean drillDownSearch(String username,
                           String tableName,
                           String queryAsString)

drillDownSearch

public ResponseBean drillDownSearch(int tenantId,
                           String tableName,
                           String queryAsString)

drillDownRangeCount

public ResponseBean drillDownRangeCount(String username,
                               String tableName,
                               String queryAsString)

drillDownRangeCount

public ResponseBean drillDownRangeCount(int tenantId,
                               String tableName,
                               String queryAsString)

drillDownSearchCount

public ResponseBean drillDownSearchCount(String username,
                                String tableName,
                                String queryAsString)

drillDownSearchCount

public ResponseBean drillDownSearchCount(int tenantId,
                                String tableName,
                                String queryAsString)

addStreamDefinition

public ResponseBean addStreamDefinition(String username,
                               String streamDefAsString)

addStreamDefinition

public ResponseBean addStreamDefinition(int tenantId,
                               String streamDefAsString)

addStreamDefinition

public ResponseBean addStreamDefinition(String streamDefAsString)

publishEvent

public ResponseBean publishEvent(String username,
                        String eventAsString)

publishEvent

public ResponseBean publishEvent(int tenantId,
                        String eventAsString)

publishEvent

public ResponseBean publishEvent(String eventAsString)

handleResponse

public ResponseBean handleResponse(AnalyticsJSServiceConnector.ResponseStatus responseStatus,
                          String message)