org.wso2.analytics.apim.integration.common.clients

Class AnalyticsWebServiceClient

java.lang.Object

org.wso2.analytics.apim.integration.common.clients.AnalyticsWebServiceClient

public class AnalyticsWebServiceClient
extends Object

Constructor Summary

Constructors

Constructor and Description
AnalyticsWebServiceClient(String backEndUrl, String sessionCookie)
AnalyticsWebServiceClient(String backEndUrl, String userName, String password)

Method Summary

Methods

Modifier and Type	Method and Description
void	addStreamDefinition(org.wso2.carbon.analytics.webservice.stub.beans.StreamDefinitionBean streamDefinitionBean)
void	clearIndices(String tableName)
void	deleteByIds(String tableName, String[] ids)
org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[]	getById(String tableName, String[] columns, String[] ids)
org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[]	getByRange(String tableName, long timeFrom, long timeTo, int recordFrom, int pageSize)
org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[]	getByRange(String tableName, String[] columns, long timeFrom, long timeTo, int recordFrom, int pageSize)
long	getRecordCount(String tableName, long timeFrom, long timeTo)
org.wso2.carbon.analytics.webservice.stub.beans.StreamDefinitionBean	getStreamDefinition(String streamName, String version)
org.wso2.carbon.analytics.webservice.stub.beans.AnalyticsSchemaBean	getTableSchema(String tableName)
org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[]	getWithKeyValues(String tableName, String[] columns, org.wso2.carbon.analytics.webservice.stub.beans.ValuesBatchBean[] valuesBatchBeans)
boolean	isPaginationSupported(String tableName)
String[]	listTables()
void	publishEvent(org.wso2.carbon.analytics.webservice.stub.beans.EventBean eventBean)
org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[]	search(String tableName, String query, int start, int count)
int	searchCount(String tableName, String query)
boolean	tableExists(String tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsWebServiceClient

public AnalyticsWebServiceClient(String backEndUrl,
                         String sessionCookie)
                          throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

AnalyticsWebServiceClient

public AnalyticsWebServiceClient(String backEndUrl,
                         String userName,
                         String password)
                          throws org.apache.axis2.AxisFault

Throws:

org.apache.axis2.AxisFault

Method Detail

getRecordCount

public long getRecordCount(String tableName,
                  long timeFrom,
                  long timeTo)
                    throws Exception

Throws:

Exception

addStreamDefinition

public void addStreamDefinition(org.wso2.carbon.analytics.webservice.stub.beans.StreamDefinitionBean streamDefinitionBean)
                         throws Exception

Throws:

Exception

getByRange

public org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[] getByRange(String tableName,
                                                                      long timeFrom,
                                                                      long timeTo,
                                                                      int recordFrom,
                                                                      int pageSize)
                                                                        throws Exception

Throws:

Exception

getByRange

public org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[] getByRange(String tableName,
                                                                      String[] columns,
                                                                      long timeFrom,
                                                                      long timeTo,
                                                                      int recordFrom,
                                                                      int pageSize)
                                                                        throws Exception

Throws:

Exception

getStreamDefinition

public org.wso2.carbon.analytics.webservice.stub.beans.StreamDefinitionBean getStreamDefinition(String streamName,
                                                                                       String version)
                                                                                         throws Exception

Throws:

Exception

publishEvent

public void publishEvent(org.wso2.carbon.analytics.webservice.stub.beans.EventBean eventBean)
                  throws Exception

Throws:

Exception

getTableSchema

public org.wso2.carbon.analytics.webservice.stub.beans.AnalyticsSchemaBean getTableSchema(String tableName)
                                                                                   throws Exception

Throws:

Exception

tableExists

public boolean tableExists(String tableName)
                    throws Exception

Throws:

Exception

listTables

public String[] listTables()
                    throws Exception

Throws:

Exception

getById

public org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[] getById(String tableName,
                                                                   String[] columns,
                                                                   String[] ids)
                                                                     throws Exception

Throws:

Exception

deleteByIds

public void deleteByIds(String tableName,
               String[] ids)
                 throws Exception

Throws:

Exception

searchCount

public int searchCount(String tableName,
              String query)
                throws Exception

Throws:

Exception

search

public org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[] search(String tableName,
                                                                  String query,
                                                                  int start,
                                                                  int count)
                                                                    throws Exception

Throws:

Exception

getWithKeyValues

public org.wso2.carbon.analytics.webservice.stub.beans.RecordBean[] getWithKeyValues(String tableName,
                                                                            String[] columns,
                                                                            org.wso2.carbon.analytics.webservice.stub.beans.ValuesBatchBean[] valuesBatchBeans)
                                                                              throws Exception

Throws:

Exception

clearIndices

public void clearIndices(String tableName)
                  throws Exception

Throws:

Exception

isPaginationSupported

public boolean isPaginationSupported(String tableName)
                              throws Exception

Throws:

Exception