com.espertech.esper.common.internal.epl.table.core

Interface Table

All Known Implementing Classes:

TableBase, TableImpl

public interface Table

Method Summary

Modifier and Type	Method and Description
void	addUpdateStrategyCallback(TableUpdateStrategyRedoCallback callback)
AggregationRowFactory	getAggregationRowFactory()
EventTableIndexMetadata	getEventTableIndexMetadata()
TableMetadataInternalEventToPublic	getEventToPublic()
TableMetaData	getMetaData()
String	getName()
PropertyHashedEventTableFactory	getPrimaryIndexFactory()
StatementContext	getStatementContextCreateTable()
TableAndLockProvider	getStateProvider(int agentInstanceId, boolean writesToTables)
TableInstance	getTableInstance(int agentInstanceId)
TableInstance	getTableInstanceNoContext()
TableSerdes	getTableSerdes()
Collection<TableUpdateStrategyRedoCallback>	getUpdateStrategyCallbacks()
boolean	isGrouped()
void	removeAllInstanceIndexes(IndexMultiKey indexMultiKey)
void	removeIndexReferencesStmtMayRemoveIndex(IndexMultiKey indexMultiKey, String deploymentId, String statementName)
void	removeUpdateStrategyCallback(TableUpdateStrategyRedoCallback callback)
void	setAggregationRowFactory(AggregationRowFactory aggregationRowFactory)
void	setEventToPublic(TableMetadataInternalEventToPublic eventToPublic)
void	setPrimaryKeyGetter(EventPropertyValueGetter primaryKeyGetter)
void	setStatementContextCreateTable(StatementContext statementContextCreateTable)
void	setTableSerdes(TableSerdes tableSerdes)
void	tableReady()
void	validateAddIndex(String deploymentId, String statementName, String indexName, String indexModuleName, QueryPlanIndexItem explicitIndexDesc, IndexMultiKey indexMultiKey)

Method Detail

setEventToPublic

void setEventToPublic(TableMetadataInternalEventToPublic eventToPublic)

setStatementContextCreateTable

void setStatementContextCreateTable(StatementContext statementContextCreateTable)

setAggregationRowFactory

void setAggregationRowFactory(AggregationRowFactory aggregationRowFactory)

setTableSerdes

void setTableSerdes(TableSerdes tableSerdes)

setPrimaryKeyGetter

void setPrimaryKeyGetter(EventPropertyValueGetter primaryKeyGetter)

tableReady

void tableReady()

getName

String getName()

getEventToPublic

TableMetadataInternalEventToPublic getEventToPublic()

getMetaData

TableMetaData getMetaData()

getTableSerdes

TableSerdes getTableSerdes()

getAggregationRowFactory

AggregationRowFactory getAggregationRowFactory()

getStateProvider

TableAndLockProvider getStateProvider(int agentInstanceId,
                                      boolean writesToTables)

getStatementContextCreateTable

StatementContext getStatementContextCreateTable()

isGrouped

boolean isGrouped()

getEventTableIndexMetadata

EventTableIndexMetadata getEventTableIndexMetadata()

getPrimaryIndexFactory

PropertyHashedEventTableFactory getPrimaryIndexFactory()

getTableInstance

TableInstance getTableInstance(int agentInstanceId)

getTableInstanceNoContext

TableInstance getTableInstanceNoContext()

validateAddIndex

void validateAddIndex(String deploymentId,
                      String statementName,
                      String indexName,
                      String indexModuleName,
                      QueryPlanIndexItem explicitIndexDesc,
                      IndexMultiKey indexMultiKey)
               throws ExprValidationException

Throws:

ExprValidationException

removeIndexReferencesStmtMayRemoveIndex

void removeIndexReferencesStmtMayRemoveIndex(IndexMultiKey indexMultiKey,
                                             String deploymentId,
                                             String statementName)

removeAllInstanceIndexes

void removeAllInstanceIndexes(IndexMultiKey indexMultiKey)

addUpdateStrategyCallback

void addUpdateStrategyCallback(TableUpdateStrategyRedoCallback callback)

removeUpdateStrategyCallback

void removeUpdateStrategyCallback(TableUpdateStrategyRedoCallback callback)

getUpdateStrategyCallbacks

Collection<TableUpdateStrategyRedoCallback> getUpdateStrategyCallbacks()