org.wso2.carbon.analytics.datasink

Class AnalyticsDSConnector

java.lang.Object

org.wso2.carbon.analytics.datasink.AnalyticsDSConnector

public class AnalyticsDSConnector
extends Object

Analytics data service connector which actually makes the interacts with DS.

Constructor Summary

Constructors

Constructor and Description
AnalyticsDSConnector()

Method Summary

Methods

Modifier and Type	Method and Description
void	addStream(int tenantId, org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)
void	deleteStream(int tenantId, org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)
void	insertEvents(int tenantId, List<org.wso2.carbon.databridge.commons.Event> events)

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsDSConnector

public AnalyticsDSConnector()

Method Detail

addStream

public void addStream(int tenantId,
             org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)
               throws org.wso2.carbon.analytics.datasource.core.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.core.AnalyticsException

insertEvents

public void insertEvents(int tenantId,
                List<org.wso2.carbon.databridge.commons.Event> events)
                  throws org.wso2.carbon.databridge.core.exception.StreamDefinitionStoreException,
                         org.wso2.carbon.analytics.datasource.core.AnalyticsException

Throws:

org.wso2.carbon.databridge.core.exception.StreamDefinitionStoreException

org.wso2.carbon.analytics.datasource.core.AnalyticsException

deleteStream

public void deleteStream(int tenantId,
                org.wso2.carbon.databridge.commons.StreamDefinition streamDefinition)
                  throws org.wso2.carbon.analytics.datasource.core.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.core.AnalyticsException