org.wso2.carbon.analytics.webservice

Class Utils

java.lang.Object

org.wso2.carbon.analytics.webservice.Utils

public class Utils
extends Object

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

Field Summary

Fields

Modifier and Type	Field and Description
static String	EMPTY_VALUE

Method Summary

Methods

Modifier and Type	Method and Description
static AggregateResponse[]	createAggregateResponses(List<org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>> iterators)
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 RecordBean	createRecordBean(org.wso2.carbon.analytics.datasource.commons.Record record) Create a RecordBean object out of a Record object
static List<RecordBean>	createRecordBeans(List<org.wso2.carbon.analytics.datasource.commons.Record> records) Creates the record beans from records.
static Map<String,RecordBean>	createRecordBeansKeyedWithIds(RecordBean[] records) Creates the record beans from records.
static AnalyticsSchemaBean	createTableSchemaBean(org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema analyticsSchema) Create table schema bean from a analytics schema
static org.wso2.carbon.analytics.dataservice.commons.AggregateRequest	getAggregateRequest(AnalyticsAggregateRequest request)
static org.wso2.carbon.analytics.dataservice.commons.AggregateRequest[]	getAggregateRequests(AnalyticsAggregateRequest[] requests)
static org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema	getAnalyticsSchema(AnalyticsSchemaBean schemaBean)
static org.wso2.carbon.databridge.commons.Event	getEvent(EventBean eventBean, org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)
static String[]	getRecordIds(List<org.wso2.carbon.analytics.dataservice.commons.SearchResultEntry> searchResults) Gets the record ids from search results.
static List<org.wso2.carbon.analytics.dataservice.commons.SortByField>	getSortByFields(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) Gets the streamDefinition object from stream definition bean class
static StreamDefinitionBean	getStreamDefinitionBean(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)
static List<Map<String,Object>>	getValuesBatch(ValuesBatchBean[] valuesBatchBeans, org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema schema)

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_VALUE

public static final String EMPTY_VALUE

See Also:

Constant Field Values

Method Detail

createRecordBeans

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

Creates the record beans from records.

Parameters:

records - the records

Returns:

the list of recordBeans

createRecordBeansKeyedWithIds

public static Map<String,RecordBean> createRecordBeansKeyedWithIds(RecordBean[] records)

Creates the record beans from records.

Parameters:

records - the records

Returns:

the Map of recordBeans with id as key and recordbean as value

createRecordBean

public static RecordBean createRecordBean(org.wso2.carbon.analytics.datasource.commons.Record record)

Create a RecordBean object out of a Record object

Parameters:

record - the record object

Returns:

RecordBean object

getRecordIds

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

Gets the record ids from search results.

Parameters:

searchResults - the search results

Returns:

the record ids from search results

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

getStreamDefinition

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

Gets the streamDefinition object from stream definition bean class

Parameters:

streamDefinitionBean - The streamDefinition bean class

Returns:

The converted StreamDefinition object.

Throws:

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

AnalyticsWebServiceException

getEvent

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

Throws:

AnalyticsWebServiceException

getStreamDefinitionBean

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

Throws:

AnalyticsWebServiceException

getValuesBatch

public static List<Map<String,Object>> getValuesBatch(ValuesBatchBean[] valuesBatchBeans,
                                      org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema schema)
                                               throws AnalyticsWebServiceException

Throws:

AnalyticsWebServiceException

getAnalyticsSchema

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

getAggregateRequest

public static org.wso2.carbon.analytics.dataservice.commons.AggregateRequest getAggregateRequest(AnalyticsAggregateRequest request)

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(AnalyticsAggregateRequest[] requests)

createAggregateResponses

public static AggregateResponse[] createAggregateResponses(List<org.wso2.carbon.analytics.datasource.commons.AnalyticsIterator<org.wso2.carbon.analytics.datasource.commons.Record>> iterators)

getSortByFields

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

Throws:

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

getSortedRecordBeans

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