com.espertech.esper.epl.table.mgmt

Interface TableService

All Known Implementing Classes:

TableServiceImpl

public interface TableService

Field Summary

Fields

Modifier and Type	Field and Description
static String	INTERNAL_RESERVED_PROPERTY

Method Summary

Modifier and Type	Method and Description
TableMetadata	addTable(String tableName, String eplExpression, String statementName, Class[] keyTypes, Map<String,TableMetadataColumn> tableColumns, TableStateRowFactory tableStateRowFactory, int numberMethodAggregations, StatementContext statementContext, ObjectArrayEventType internalEventType, ObjectArrayEventType publicEventType, TableMetadataInternalEventToPublic eventToPublic, boolean queryPlanLogging)
void	addTableUpdateStrategyReceiver(TableMetadata tableMetadata, String statementName, TableUpdateStrategyReceiver receiver, EventBeanUpdateHelper updateHelper, boolean isOnMerge)
Collection<Integer>	getAgentInstanceIds(String tableName)
TableStateInstance	getState(String name, int agentInstanceId)
TableAndLockProvider	getStateProvider(String tableName, int agentInstanceId, boolean writesToTables)
TableExprEvaluatorContext	getTableExprEvaluatorContext()
ExprTableIdentNode	getTableIdentNode(StreamTypeService streamTypeService, String unresolvedPropertyName, String streamOrPropertyName)
TableMetadata	getTableMetadata(String tableName)
TableMetadata	getTableMetadataFromEventType(EventType type)
Pair<ExprNode,List<ExprChainedSpec>>	getTableNodeChainable(StreamTypeService streamTypeService, List<ExprChainedSpec> chainSpec, EngineImportService engineImportService)
String[]	getTables()
TableUpdateStrategy	getTableUpdateStrategy(TableMetadata tableMetadata, EventBeanUpdateHelper updateHelper, boolean isOnMerge)
void	removeIndexReferencesStmtMayRemoveIndex(String statementName, TableMetadata tableMetadata)
void	removeTableIfFound(String tableName)
void	removeTableUpdateStrategyReceivers(TableMetadata tableMetadata, String statementName)
void	validateAddIndex(String createIndexStatementName, TableMetadata tableMetadata, String explicitIndexName, QueryPlanIndexItem explicitIndexDesc, IndexMultiKey imk)

Field Detail

INTERNAL_RESERVED_PROPERTY

static final String INTERNAL_RESERVED_PROPERTY

See Also:

Constant Field Values

Method Detail

getTables

String[] getTables()

getTableExprEvaluatorContext

TableExprEvaluatorContext getTableExprEvaluatorContext()

getTableMetadata

TableMetadata getTableMetadata(String tableName)

getState

TableStateInstance getState(String name,
                            int agentInstanceId)

removeTableIfFound

void removeTableIfFound(String tableName)

getTableIdentNode

ExprTableIdentNode getTableIdentNode(StreamTypeService streamTypeService,
                                     String unresolvedPropertyName,
                                     String streamOrPropertyName)
                              throws ExprValidationException

Throws:

ExprValidationException

getTableMetadataFromEventType

TableMetadata getTableMetadataFromEventType(EventType type)

getTableNodeChainable

Pair<ExprNode,List<ExprChainedSpec>> getTableNodeChainable(StreamTypeService streamTypeService,
                                                           List<ExprChainedSpec> chainSpec,
                                                           EngineImportService engineImportService)
                                                    throws ExprValidationException

Throws:

ExprValidationException

getAgentInstanceIds

Collection<Integer> getAgentInstanceIds(String tableName)

getTableUpdateStrategy

TableUpdateStrategy getTableUpdateStrategy(TableMetadata tableMetadata,
                                           EventBeanUpdateHelper updateHelper,
                                           boolean isOnMerge)
                                    throws ExprValidationException

Throws:

ExprValidationException

addTableUpdateStrategyReceiver

void addTableUpdateStrategyReceiver(TableMetadata tableMetadata,
                                    String statementName,
                                    TableUpdateStrategyReceiver receiver,
                                    EventBeanUpdateHelper updateHelper,
                                    boolean isOnMerge)

removeTableUpdateStrategyReceivers

void removeTableUpdateStrategyReceivers(TableMetadata tableMetadata,
                                        String statementName)

validateAddIndex

void validateAddIndex(String createIndexStatementName,
                      TableMetadata tableMetadata,
                      String explicitIndexName,
                      QueryPlanIndexItem explicitIndexDesc,
                      IndexMultiKey imk)
               throws ExprValidationException

Throws:

ExprValidationException

removeIndexReferencesStmtMayRemoveIndex

void removeIndexReferencesStmtMayRemoveIndex(String statementName,
                                             TableMetadata tableMetadata)

addTable

TableMetadata addTable(String tableName,
                       String eplExpression,
                       String statementName,
                       Class[] keyTypes,
                       Map<String,TableMetadataColumn> tableColumns,
                       TableStateRowFactory tableStateRowFactory,
                       int numberMethodAggregations,
                       StatementContext statementContext,
                       ObjectArrayEventType internalEventType,
                       ObjectArrayEventType publicEventType,
                       TableMetadataInternalEventToPublic eventToPublic,
                       boolean queryPlanLogging)
                throws ExprValidationException

Throws:

ExprValidationException

getStateProvider

TableAndLockProvider getStateProvider(String tableName,
                                      int agentInstanceId,
                                      boolean writesToTables)