org.wso2.carbon.analytics.stream.persistence

Class EventStreamPersistenceAdminService

java.lang.Object

org.wso2.carbon.core.AbstractAdmin

org.wso2.carbon.analytics.stream.persistence.EventStreamPersistenceAdminService

public class EventStreamPersistenceAdminService
extends org.wso2.carbon.core.AbstractAdmin

This class represent Event Stream Persistence admin operations

Field Summary

Fields inherited from class org.wso2.carbon.core.AbstractAdmin

axisConfig, configurationContext

Constructor Summary

Constructors

Constructor and Description
EventStreamPersistenceAdminService()

Method Summary

Modifier and Type	Method and Description
void	addAnalyticsTable(AnalyticsTable analyticsTable) This method will create a deployable artifact for given AnalyticsTable information.
AnalyticsTable	getAnalyticsTable(String streamName, String version) This method is use to get Analytics table information for given stream name without considering the version
boolean	isBackendServicePresent() This method use to check whether back-end is available for the UI to show analytics table related operation
String[]	listRecordStoreNames() This method will return all the available records store names;

Methods inherited from class org.wso2.carbon.core.AbstractAdmin

getAxisConfig, getConfigContext, getConfigSystemRegistry, getConfigUserRegistry, getGovernanceRegistry, getGovernanceSystemRegistry, getGovernanceUserRegistry, getHttpSession, getLocalRepo, getRegistry, getTenantDomain, getUsername, getUserRealm, setConfigurationContext, setPermissionUpdateTimestamp

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStreamPersistenceAdminService

public EventStreamPersistenceAdminService()

Method Detail

isBackendServicePresent

public boolean isBackendServicePresent()

This method use to check whether back-end is available for the UI to show analytics table related operation

Returns:

true if back-end service available

getAnalyticsTable

public AnalyticsTable getAnalyticsTable(String streamName,
                                        String version)
                                 throws EventStreamPersistenceAdminServiceException

This method is use to get Analytics table information for given stream name without considering the version

Parameters:

streamName - stream name

version - stream version

Returns:

AnalyticsTable instance with column details

Throws:

EventStreamPersistenceAdminServiceException

addAnalyticsTable

public void addAnalyticsTable(AnalyticsTable analyticsTable)
                       throws EventStreamPersistenceAdminServiceException

This method will create a deployable artifact for given AnalyticsTable information.

Parameters:

analyticsTable - AnalyticsTable object with index and type information

Throws:

EventStreamPersistenceAdminServiceException

listRecordStoreNames

public String[] listRecordStoreNames()

This method will return all the available records store names;

Returns:

Array of String that contains the record store names