org.wso2.carbon.analytics.jsservice

Class Utils

java.lang.Object

org.wso2.carbon.analytics.jsservice.Utils

public class Utils
extends Object

This class represents a set of utility functionalities for the analytics REST API.

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Methods

Modifier and Type	Method and Description
static String[]	authenticate(String authHeader) Authenticate an user given the auth header (basic auth ) Note : This method is used in jaggery page, Do not remove.
static org.wso2.carbon.analytics.dataservice.commons.CategoryDrillDownRequest	createCategoryDrillDownRequest(String tableName, CategoryDrillDownRequestBean queryBean)
static org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest	createDrillDownSearchRequest(String tableName, DrillDownRequestBean queryBean)
static List<org.wso2.carbon.analytics.datasource.commons.Record>	createList(org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> iterator)
static AnalyticsSchemaBean	createTableSchemaBean(org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema analyticsSchema) Create table schema bean from a analytics schema
static List<List<RecordBean>>	getAggregatedRecordsForMultipleTables(List<org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>> iterators)
static org.wso2.carbon.analytics.dataservice.commons.AggregateRequest	getAggregateRequest(AggregateRequestBean aggregateRequest)
static org.wso2.carbon.analytics.dataservice.commons.AggregateRequest	getAggregateRequest(AggregateRequestBean aggregateRequest, String tableName)
static org.wso2.carbon.analytics.dataservice.commons.AggregateRequest[]	getAggregateRequests(AggregateRequestBean[] aggregateRequests)
static org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema	getAnalyticsSchema(AnalyticsSchemaBean schemaBean) Create a Analytics schema from a bean class
static List<DrillDownRangeBean>	getDrilldownRangeBean(List<org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRange> searchResults)
static List<String>	getIds(List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> searchResults)
static Map<String,RecordBean>	getRecordBeanKeyedWithIds(List<org.wso2.carbon.analytics.datasource.commons.Record> records)
static List<RecordBean>	getRecordBeans(List<org.wso2.carbon.analytics.datasource.commons.Record> records)
static List<org.wso2.carbon.analytics.dataservice.commons.SortByField>	getSortedFields(List<SortByFieldBean> sortByFieldBeans)
static List<RecordBean>	getSortedRecordBeans(Map<String,RecordBean> recordBeanMap, List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> searchResults)
static org.wso2.carbon.databridge.commons.StreamDefinition	getStreamDefinition(StreamDefinitionBean streamDefinitionBean)
static StreamDefinitionBean	getStreamDefinitionBean(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)
static org.wso2.carbon.databridge.commons.Event	getStreamEvent(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition, EventBean eventBean)
static SubCategoriesBean	getSubCategories(org.wso2.carbon.analytics.dataservice.commons.SubCategories searchResults)
static boolean	startTenantFlow(int tenantId)

Methods inherited from class java.lang.Object

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

Constructor Detail

Utils

public Utils()

Method Detail

getRecordBeans

public static List<RecordBean> getRecordBeans(List<org.wso2.carbon.analytics.datasource.commons.Record> records)

getIds

public static List<String> getIds(List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> searchResults)

getAnalyticsSchema

public static org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema getAnalyticsSchema(AnalyticsSchemaBean schemaBean)

Create a Analytics schema from a bean class

Parameters:

schemaBean - bean table schema to be converted to Analytics Schema.

Returns:

Analytics schema

createTableSchemaBean

public static AnalyticsSchemaBean createTableSchemaBean(org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema analyticsSchema)

Create table schema bean from a analytics schema

Parameters:

analyticsSchema - Analytics schema to be converted to table schema bean

Returns:

Table schema bean

createCategoryDrillDownRequest

public static org.wso2.carbon.analytics.dataservice.commons.CategoryDrillDownRequest createCategoryDrillDownRequest(String tableName,
                                                                                                    CategoryDrillDownRequestBean queryBean)

createDrillDownSearchRequest

public static org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRequest createDrillDownSearchRequest(String tableName,
                                                                                                   DrillDownRequestBean queryBean)
                                                                                                            throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

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

getSubCategories

public static SubCategoriesBean getSubCategories(org.wso2.carbon.analytics.dataservice.commons.SubCategories searchResults)

authenticate

public static String[] authenticate(String authHeader)
                             throws UnauthenticatedUserException

Authenticate an user given the auth header (basic auth ) Note : This method is used in jaggery page, Do not remove.

Parameters:

authHeader -

Returns:

Throws:

UnauthenticatedUserException

getStreamDefinition

public static org.wso2.carbon.databridge.commons.StreamDefinition getStreamDefinition(StreamDefinitionBean streamDefinitionBean)
                                                                               throws org.wso2.carbon.databridge.commons.exception.MalformedStreamDefinitionException,
                                                                                      JSServiceException

Throws:

org.wso2.carbon.databridge.commons.exception.MalformedStreamDefinitionException

JSServiceException

getStreamEvent

public static org.wso2.carbon.databridge.commons.Event getStreamEvent(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition,
                                                      EventBean eventBean)
                                                               throws JSServiceException

Throws:

JSServiceException

getStreamDefinitionBean

public static StreamDefinitionBean getStreamDefinitionBean(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)

getAggregateRequest

public static org.wso2.carbon.analytics.dataservice.commons.AggregateRequest getAggregateRequest(AggregateRequestBean aggregateRequest)

getAggregateRequest

public static org.wso2.carbon.analytics.dataservice.commons.AggregateRequest getAggregateRequest(AggregateRequestBean aggregateRequest,
                                                                                 String tableName)

createList

public static List<org.wso2.carbon.analytics.datasource.commons.Record> createList(org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record> iterator)

getAggregateRequests

public static org.wso2.carbon.analytics.dataservice.commons.AggregateRequest[] getAggregateRequests(AggregateRequestBean[] aggregateRequests)

getAggregatedRecordsForMultipleTables

public static List<List<RecordBean>> getAggregatedRecordsForMultipleTables(List<org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>> iterators)

getSortedFields

public static List<org.wso2.carbon.analytics.dataservice.commons.SortByField> getSortedFields(List<SortByFieldBean> sortByFieldBeans)
                                                                                       throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

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

getRecordBeanKeyedWithIds

public static Map<String,RecordBean> getRecordBeanKeyedWithIds(List<org.wso2.carbon.analytics.datasource.commons.Record> records)

getSortedRecordBeans

public static List<RecordBean> getSortedRecordBeans(Map<String,RecordBean> recordBeanMap,
                                    List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> searchResults)

startTenantFlow

public static boolean startTenantFlow(int tenantId)

getDrilldownRangeBean

public static List<DrillDownRangeBean> getDrilldownRangeBean(List<org.wso2.carbon.analytics.dataservice.commons.AnalyticsDrillDownRange> searchResults)