| Package | Description |
|---|---|
| org.wso2.carbon.analytics.webservice |
| Modifier and Type | Method and Description |
|---|---|
String |
AnalyticsWebService.addStreamDefinition(StreamDefinitionBean streamDefinitionBean)
Add a stream definition using the Event stream publisher.
|
void |
AnalyticsWebService.clearIndices(String tableName)
Clears all the indices for the given table.
|
void |
AnalyticsWebService.createTable(String recordStoreName,
String tableName)
Creates a table, if not already there, where the columns are not defined here, but can contain any arbitrary number
of columns when data is added.
|
void |
AnalyticsWebService.deleteByIds(String tableName,
String[] ids)
Delete data in a table with given ids.
|
void |
AnalyticsWebService.destroy()
Destroys and frees any resources taken up by the analytics data service implementation.
|
SubCategoriesBean |
AnalyticsWebService.drillDownCategories(CategoryDrillDownRequestBean drillDownRequest)
Returns the subcategories of a facet field, given CategoryDrillDownRequestBean
|
RecordBean[] |
AnalyticsWebService.drillDownSearch(AnalyticsDrillDownRequestBean drillDownRequest)
Returns the drill down results of a search query, given AnalyticsDrillDownRequestBean
|
double |
AnalyticsWebService.drillDownSearchCount(AnalyticsDrillDownRequestBean drillDownRequest)
Returns the count of results of a search query, given AnalyticsDrillDownRequestBean
|
RecordBean[] |
AnalyticsWebService.getById(String tableName,
int numPartitionsHint,
String[] columns,
String[] ids)
Retrieves data from a table with given ids.
|
RecordBean[] |
AnalyticsWebService.getByRange(String tableName,
int numPartitionsHint,
String[] columns,
long timeFrom,
long timeTo,
int recordsFrom,
int recordsCount)
Retrieves data from a table, with a given range.
|
static org.wso2.carbon.databridge.commons.Event |
Utils.getEvent(EventBean eventBean,
org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition) |
long |
AnalyticsWebService.getRecordCount(String tableName,
long timeFrom,
long timeTo)
Returns the number of records in the table with the given category and name.
|
String |
AnalyticsWebService.getRecordStoreNameByTable(String tableName)
Returns the record store name given the table information.
|
static org.wso2.carbon.databridge.commons.StreamDefinition |
Utils.getStreamDefinition(StreamDefinitionBean streamDefinitionBean)
Gets the streamDefinition object from stream definition bean class
|
StreamDefinitionBean |
AnalyticsWebService.getStreamDefinition(String name,
String version)
get the stream definition using the Event stream publisher.
|
static StreamDefinitionBean |
Utils.getStreamDefinitionBean(org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition) |
AnalyticsSchemaBean |
AnalyticsWebService.getTableSchema(String tableName)
Retrieves the table schema for the given table.
|
static List<Map<String,Object>> |
Utils.getValuesBatch(ValuesBatchBean[] valuesBatchBeans,
org.wso2.carbon.analytics.datasource.commons.AnalyticsSchema schema) |
RecordBean[] |
AnalyticsWebService.getWithKeyValues(String tableName,
int numPartitionsHint,
String[] columns,
ValuesBatchBean[] valuesBatchBeans)
Retrieves data from a table, which matches the primary key values batch.
|
boolean |
AnalyticsWebService.isPaginationSupported(String recordStoreName)
Check whether under laying data layer implementation support for pagination or not.
|
boolean |
AnalyticsWebService.isRecordCountSupported(String recordStoreName)
Check whether under laying data layer implementation support for get total record count operation or not.
|
List<String> |
AnalyticsWebService.listRecordStoreNames()
Lists all the record stores available in the system.
|
String[] |
AnalyticsWebService.listTables()
Lists all the current tables with the given category.
|
void |
AnalyticsWebService.publishEvent(EventBean eventBean)
Publishes events to a given stream represented by stream id.
|
void |
AnalyticsWebService.reIndex(String tableName,
long startTime,
long endTime)
Given the start time and end time, this method will re-index the records of a table.
|
void |
AnalyticsWebService.removeStreamDefinition(String name,
String version)
This method can use to remove existing stream definition from system using the Event stream publisher.
|
RecordBean[] |
AnalyticsWebService.search(String tableName,
String query,
int start,
int count)
Searches the data with a given search query.
|
int |
AnalyticsWebService.searchCount(String tableName,
String query)
Returns the search count of results of a given search query.
|
AggregateResponse[] |
AnalyticsWebService.searchMultiTablesWithAggregates(AnalyticsAggregateRequest[] requests)
Returns a list of records containing the aggregate values computed over the given fields map
, grouped by a predefined FACET field for multiple tables.
|
RecordBean[] |
AnalyticsWebService.searchWithAggregates(AnalyticsAggregateRequest request)
Returns a list of records containing the aggregate values computed over the given fields map
, grouped by a predefined FACET field.
|
RecordBean[] |
AnalyticsWebService.searchWithSorting(String tableName,
String query,
int start,
int count,
String[] columns,
SortByFieldBean[] sortByFields)
Searches the data with a given search query.
|
void |
AnalyticsWebService.setTableSchema(String tableName,
AnalyticsSchemaBean schemaBean)
Sets the table schema for a table
|
boolean |
AnalyticsWebService.tableExists(String tableName)
Checks if the specified table with the given category and name exists.
|
void |
AnalyticsWebService.waitForIndexing(long maxWait)
This method waits until the current indexing operations for the system is done.
|
void |
AnalyticsWebService.waitForIndexingForTable(String tableName,
long maxWait)
This method waits until the current indexing operations for a given table is done.
|
Copyright © 2016 WSO2. All rights reserved.