A C D E F G I J L M N O R S T U V

A

activate(ComponentContext) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceComponent

AnalyticsClusterException - Exception in org.wso2.carbon.analytics.dataservice.clustering

This represents analytics clustering related exceptions.

AnalyticsClusterException(String) - Constructor for exception org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterException

AnalyticsClusterException(String, Throwable) - Constructor for exception org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterException

AnalyticsClusterManager - Interface in org.wso2.carbon.analytics.dataservice.clustering

This interface represents the analytics clustering related operations.

AnalyticsClusterManagerImpl - Class in org.wso2.carbon.analytics.dataservice.clustering

This class represents an AnalyticsClusterManager implementation.

AnalyticsClusterManagerImpl() - Constructor for class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

AnalyticsClusterManagerImpl.LeaderUpdateNotification - Class in org.wso2.carbon.analytics.dataservice.clustering

This class represents the cluster message that notifies the cluster of a new leader

AnalyticsClusterManagerImpl.LeaderUpdateNotification(String) - Constructor for class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl.LeaderUpdateNotification

AnalyticsDataIndexer - Class in org.wso2.carbon.analytics.dataservice.indexing

This class represents the indexing functionality.

AnalyticsDataIndexer(AnalyticsFileSystem) - Constructor for class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

AnalyticsDataService - Interface in org.wso2.carbon.analytics.dataservice

This interface represents the analytics data service operations.

AnalyticsDataServiceComponent - Class in org.wso2.carbon.analytics.dataservice

This class represents the analytics data service declarative services component.

AnalyticsDataServiceComponent() - Constructor for class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceComponent

AnalyticsDataServiceConfigProperty - Class in org.wso2.carbon.analytics.dataservice.config

This class represents an analytics data service configuration property.

AnalyticsDataServiceConfigProperty() - Constructor for class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfigProperty

AnalyticsDataServiceConfiguration - Class in org.wso2.carbon.analytics.dataservice.config

This class represents the configuration for analytics data service.

AnalyticsDataServiceConfiguration() - Constructor for class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfiguration

AnalyticsDataServiceImpl - Class in org.wso2.carbon.analytics.dataservice

The implementation of AnalyticsDataService.

AnalyticsDataServiceImpl(AnalyticsRecordStore, AnalyticsFileSystem) - Constructor for class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

AnalyticsDataServiceImpl(AnalyticsDataServiceConfiguration) - Constructor for class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

AnalyticsDirectory - Class in org.wso2.carbon.analytics.dataservice

This represents a Lucene Directory implementation using Carbon Analytics AnalyticsFileSystem.

AnalyticsDirectory(AnalyticsFileSystem, LockFactory, String) - Constructor for class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

AnalyticsDirectory.InMemoryLockFactory - Class in org.wso2.carbon.analytics.dataservice

AnalyticsDirectory.InMemoryLockFactory(String) - Constructor for class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory.InMemoryLockFactory

AnalyticsDirectory.InMemoryLockFactory.InMemoryLock - Class in org.wso2.carbon.analytics.dataservice

AnalyticsDirectory.InMemoryLockFactory.InMemoryLock(String) - Constructor for class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory.InMemoryLockFactory.InMemoryLock

AnalyticsDSUtils - Class in org.wso2.carbon.analytics.dataservice

This class contains utility methods for analytics data service.

AnalyticsDSUtils() - Constructor for class org.wso2.carbon.analytics.dataservice.AnalyticsDSUtils

AnalyticsFileSystemConfiguration - Class in org.wso2.carbon.analytics.dataservice.config

This represents the configuration section for analytics file system.

AnalyticsFileSystemConfiguration() - Constructor for class org.wso2.carbon.analytics.dataservice.config.AnalyticsFileSystemConfiguration

AnalyticsIndexDefinitionRepository - Class in org.wso2.carbon.analytics.dataservice.indexing

This class represents a repository for storing index definitions.

AnalyticsIndexDefinitionRepository(AnalyticsFileSystem) - Constructor for class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsIndexDefinitionRepository

AnalyticsIndexException - Exception in org.wso2.carbon.analytics.dataservice

This class represents analytics indexing related exceptions.

AnalyticsIndexException(String) - Constructor for exception org.wso2.carbon.analytics.dataservice.AnalyticsIndexException

AnalyticsIndexException(String, Throwable) - Constructor for exception org.wso2.carbon.analytics.dataservice.AnalyticsIndexException

AnalyticsQueryParser - Class in org.wso2.carbon.analytics.dataservice

This represents a custom QueryParser implementation, with index data type awareness, specifically, in handling numbers.

AnalyticsQueryParser(Analyzer, Map<String, IndexType>) - Constructor for class org.wso2.carbon.analytics.dataservice.AnalyticsQueryParser

AnalyticsRecordStoreConfiguration - Class in org.wso2.carbon.analytics.dataservice.config

This represents the configuration section for analytics record store.

AnalyticsRecordStoreConfiguration() - Constructor for class org.wso2.carbon.analytics.dataservice.config.AnalyticsRecordStoreConfiguration

AnalyticsServiceHolder - Class in org.wso2.carbon.analytics.dataservice

This represents a service holder class for analytics data service.

AnalyticsServiceHolder() - Constructor for class org.wso2.carbon.analytics.dataservice.AnalyticsServiceHolder

C

call() - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl.LeaderUpdateNotification

clearAllIndices(int, String) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsIndexDefinitionRepository

clearIndices(int, String) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Clears all the indices for the given table.

clearIndices(int, String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

clearIndices(int, String) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

clearLock(String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

clearLock(String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory.InMemoryLockFactory

close() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

close() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory.InMemoryLockFactory.InMemoryLock

close() - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

clusterNoficationReceived(int, String) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

compareTo(SearchResultEntry) - Method in class org.wso2.carbon.analytics.dataservice.indexing.SearchResultEntry

createOutput(String, IOContext) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

createTable(int, String) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

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.

createTable(int, String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

D

delete(int, String, long, long) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Deletes a set of records in the table.

delete(int, String, List<String>) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Delete data in a table with given ids.

delete(int, String, long, long) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

delete(int, String, List<String>) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

delete(int, String, List<String>) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

Deletes the given records in the index.

delete(int, String, long, long) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

Deletes the records in the index with the given time range.

deleteFile(String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

deleteTable(int, String) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Deletes the table with the given category and name if a table exists already.

deleteTable(int, String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

destroy() - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Destroys and frees any resources taken up by the analytics data service implementation.

destroy() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

E

execute(String, Callable<T>) - Method in interface org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManager

Executes the given Callable in all the nodes in the group, including the current one.

execute(String, Callable<T>) - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

F

fileExists(String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

fileLength(String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

G

get(int, String, List<String>, long, long, int, int) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Retrieves data from a table.

get(int, String, List<String>, List<String>) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Retrieves data from a table with given ids.

get(int, String, List<String>, long, long, int, int) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

get(int, String, List<String>, List<String>) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

getAnalyticsClusterManager() - Static method in class org.wso2.carbon.analytics.dataservice.AnalyticsServiceHolder

getAnalyticsFileSystemConfiguration() - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfiguration

getAnalyticsRecordStore() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

getAnalyticsRecordStoreConfiguration() - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfiguration

getFileSystem() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

getFileSystem() - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

getGroupId() - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl.LeaderUpdateNotification

getHazelcastInstance() - Static method in class org.wso2.carbon.analytics.dataservice.AnalyticsServiceHolder

getId() - Method in class org.wso2.carbon.analytics.dataservice.indexing.SearchResultEntry

getImplementation() - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsFileSystemConfiguration

getImplementation() - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsRecordStoreConfiguration

getIndexer() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

getIndices(int, String) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Returns the declared indices for a given table under the given tenant.

getIndices(int, String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

getIndices(int, String) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsIndexDefinitionRepository

getLockFactory() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

getName() - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfigProperty

getPath() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

getProperties() - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsFileSystemConfiguration

getProperties() - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsRecordStoreConfiguration

getProperty(String, String) - Method in interface org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManager

Retrieves a property local to a given group.

getProperty(String, String) - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

getRangeQuery(String, String, String, boolean, boolean) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsQueryParser

getRecordCount(int, String) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Returns the number of records in the table with the given category and name.

getRecordCount(int, String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

getRepository() - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

getScore() - Method in class org.wso2.carbon.analytics.dataservice.indexing.SearchResultEntry

getValue() - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfigProperty

GroupEventListener - Interface in org.wso2.carbon.analytics.dataservice.clustering

This interface represents the listener for analytics cluster group related events.

I

INDEX_ID_INTERNAL_FIELD - Static variable in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

INDEX_INTERNAL_TIMESTAMP_FIELD - Static variable in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

IndexType - Enum in org.wso2.carbon.analytics.dataservice.indexing

Index type definitions.

insert(List<Record>) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Adds a new record to the table.

insert(List<Record>) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

insert(List<Record>) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

Adds the given records to the index if they are previously scheduled to be indexed.

isClusteringEnabled() - Method in interface org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManager

Checks if the server is in clustered mode.

isClusteringEnabled() - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

isLocked() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory.InMemoryLockFactory.InMemoryLock

J

joinGroup(String, GroupEventListener) - Method in interface org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManager

Joins a given group.

joinGroup(String, GroupEventListener) - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

L

listAll() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

listRecords(AnalyticsDataService, RecordGroup[]) - Static method in class org.wso2.carbon.analytics.dataservice.AnalyticsDSUtils

listTables(int) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Lists all the current tables with the given category.

listTables(int) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

lookupIndices(int, String) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

M

makeLock(String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory.InMemoryLockFactory

makeLock(String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

memberAdded(MembershipEvent) - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

memberAttributeChanged(MemberAttributeEvent) - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

memberRemoved(MembershipEvent) - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

N

newTermQuery(Term) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsQueryParser

O

obtain() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory.InMemoryLockFactory.InMemoryLock

onBecomingLeader() - Method in interface org.wso2.carbon.analytics.dataservice.clustering.GroupEventListener

Called when the current node becomes the leader of the given group.

onLeaderUpdate() - Method in interface org.wso2.carbon.analytics.dataservice.clustering.GroupEventListener

Called when the group leadership updates, this is called even when the new leader is the current node, and this call is made after the leader's onBecomingLeader has fully executed, so the leader can do any initializations before telling the cluster that he is the leader.

openInput(String, IOContext) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

org.wso2.carbon.analytics.dataservice - package org.wso2.carbon.analytics.dataservice

org.wso2.carbon.analytics.dataservice.clustering - package org.wso2.carbon.analytics.dataservice.clustering

org.wso2.carbon.analytics.dataservice.config - package org.wso2.carbon.analytics.dataservice.config

org.wso2.carbon.analytics.dataservice.indexing - package org.wso2.carbon.analytics.dataservice.indexing

R

readRecords(RecordGroup) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Reads in the records from a given record group, the records will be streamed in.

readRecords(RecordGroup) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

S

search(int, String, String, String, int, int) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Searches the data with a given search query.

search(int, String, String, String, int, int) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

search(int, String, String, String, int, int) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

searchCount(int, String, String, String) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Returns the search count of results of a given search query.

searchCount(int, String, String, String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

searchCount(int, String, String, String) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

SearchResultEntry - Class in org.wso2.carbon.analytics.dataservice.indexing

This represents a search result entry from AnalyticsDataIndexer.

SearchResultEntry(String, float) - Constructor for class org.wso2.carbon.analytics.dataservice.indexing.SearchResultEntry

setAnalyticsClusterManager(AnalyticsClusterManager) - Static method in class org.wso2.carbon.analytics.dataservice.AnalyticsServiceHolder

setAnalyticsFileSystemConfiguration(AnalyticsFileSystemConfiguration) - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfiguration

setAnalyticsRecordStoreConfiguration(AnalyticsRecordStoreConfiguration) - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfiguration

setHazelcastInstance(HazelcastInstance) - Static method in class org.wso2.carbon.analytics.dataservice.AnalyticsServiceHolder

setImplementation(String) - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsFileSystemConfiguration

setImplementation(String) - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsRecordStoreConfiguration

setIndices(int, String, Map<String, IndexType>) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Sets the indices for a given table under the given tenant.

setIndices(int, String, Map<String, IndexType>) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

setIndices(int, String, Map<String, IndexType>) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

setIndices(int, String, Map<String, IndexType>) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsIndexDefinitionRepository

setLockFactory(LockFactory) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

setName(String) - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfigProperty

setProperties(AnalyticsDataServiceConfigProperty[]) - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsFileSystemConfiguration

setProperties(AnalyticsDataServiceConfigProperty[]) - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsRecordStoreConfiguration

setProperty(String, String, Serializable) - Method in interface org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManager

Sets a property local to the given group.

setProperty(String, String, Serializable) - Method in class org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

setRegistryService(RegistryService) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceComponent

setValue(String) - Method in class org.wso2.carbon.analytics.dataservice.config.AnalyticsDataServiceConfigProperty

sync(Collection<String>) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory

T

tableExists(int, String) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Checks if the specified table with the given category and name exists.

tableExists(int, String) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

toString() - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDirectory.InMemoryLockFactory.InMemoryLock

U

unsetRegistryService(RegistryService) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceComponent

update(List<Record>) - Method in interface org.wso2.carbon.analytics.dataservice.AnalyticsDataService

Updates the record store with the given records, matches by its record ids, this will be a full replace of the record, where the older record is effectively deleted and the new one is added, there will not be a merge of older record's field's with the new one.

update(List<Record>) - Method in class org.wso2.carbon.analytics.dataservice.AnalyticsDataServiceImpl

update(List<Record>) - Method in class org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

Updates the given records in the index.

V

valueOf(String) - Static method in enum org.wso2.carbon.analytics.dataservice.indexing.IndexType

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.wso2.carbon.analytics.dataservice.indexing.IndexType

Returns an array containing the constants of this enum type, in the order they are declared.

A C D E F G I J L M N O R S T U V