org.wso2.carbon.analytics.dataservice.indexing

Class AnalyticsDataIndexer

java.lang.Object

org.wso2.carbon.analytics.dataservice.indexing.AnalyticsDataIndexer

public class AnalyticsDataIndexer
extends Object

This class represents the indexing functionality.

Field Summary

Fields

Modifier and Type	Field and Description
static String	INDEX_ID_INTERNAL_FIELD
static String	INDEX_INTERNAL_TIMESTAMP_FIELD

Constructor Summary

Constructors

Constructor and Description
AnalyticsDataIndexer(org.wso2.carbon.analytics.datasource.core.AnalyticsFileSystem analyticsFileSystem)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearIndices(int tenantId, String tableName)
void	close()
void	clusterNoficationReceived(int tenantId, String tableName)
void	delete(int tenantId, String tableName, List<String> ids) Deletes the given records in the index.
void	delete(int tenantId, String tableName, long timeFrom, long timeTo) Deletes the records in the index with the given time range.
org.wso2.carbon.analytics.datasource.core.AnalyticsFileSystem	getFileSystem()
AnalyticsIndexDefinitionRepository	getRepository()
void	insert(List<org.wso2.carbon.analytics.datasource.core.Record> records) Adds the given records to the index if they are previously scheduled to be indexed.
Map<String,IndexType>	lookupIndices(int tenantId, String tableName)
List<SearchResultEntry>	search(int tenantId, String tableName, String language, String query, int start, int count)
int	searchCount(int tenantId, String tableName, String language, String query)
void	setIndices(int tenantId, String tableName, Map<String,IndexType> columns)
void	update(List<org.wso2.carbon.analytics.datasource.core.Record> records) Updates the given records in the index.

Methods inherited from class java.lang.Object

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

Field Detail

INDEX_ID_INTERNAL_FIELD

public static final String INDEX_ID_INTERNAL_FIELD

See Also:

Constant Field Values

INDEX_INTERNAL_TIMESTAMP_FIELD

public static final String INDEX_INTERNAL_TIMESTAMP_FIELD

See Also:

Constant Field Values

Constructor Detail

AnalyticsDataIndexer

public AnalyticsDataIndexer(org.wso2.carbon.analytics.datasource.core.AnalyticsFileSystem analyticsFileSystem)

Method Detail

getFileSystem

public org.wso2.carbon.analytics.datasource.core.AnalyticsFileSystem getFileSystem()

getRepository

public AnalyticsIndexDefinitionRepository getRepository()

search

public List<SearchResultEntry> search(int tenantId,
                             String tableName,
                             String language,
                             String query,
                             int start,
                             int count)
                               throws AnalyticsIndexException

Throws:

AnalyticsIndexException

searchCount

public int searchCount(int tenantId,
              String tableName,
              String language,
              String query)
                throws AnalyticsIndexException

Throws:

AnalyticsIndexException

insert

public void insert(List<org.wso2.carbon.analytics.datasource.core.Record> records)
            throws org.wso2.carbon.analytics.datasource.core.AnalyticsException

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

Parameters:

records - The records to be indexed

Throws:

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

update

public void update(List<org.wso2.carbon.analytics.datasource.core.Record> records)
            throws org.wso2.carbon.analytics.datasource.core.AnalyticsException

Updates the given records in the index.

Parameters:

records - The records to be indexed

Throws:

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

delete

public void delete(int tenantId,
          String tableName,
          List<String> ids)
            throws org.wso2.carbon.analytics.datasource.core.AnalyticsException

Deletes the given records in the index.

Parameters:

tenantId - The tenant id

tableName - The table name

The - ids of the records to be deleted

Throws:

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

delete

public void delete(int tenantId,
          String tableName,
          long timeFrom,
          long timeTo)
            throws org.wso2.carbon.analytics.datasource.core.AnalyticsException

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

Parameters:

tenantId - The tenant id

tableName - The table name

timeFrom - The from time of records, inclusive

timeTo - The to time of records, non-inclusive

Throws:

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

setIndices

public void setIndices(int tenantId,
              String tableName,
              Map<String,IndexType> columns)
                throws AnalyticsIndexException

Throws:

AnalyticsIndexException

lookupIndices

public Map<String,IndexType> lookupIndices(int tenantId,
                                  String tableName)
                                    throws AnalyticsIndexException

Throws:

AnalyticsIndexException

clearIndices

public void clearIndices(int tenantId,
                String tableName)
                  throws AnalyticsIndexException

Throws:

AnalyticsIndexException

clusterNoficationReceived

public void clusterNoficationReceived(int tenantId,
                             String tableName)
                               throws AnalyticsIndexException

Throws:

AnalyticsIndexException

close

public void close()
           throws AnalyticsIndexException

Throws:

AnalyticsIndexException