com.espertech.esper.epl.table.mgmt

Class TableServiceImpl

java.lang.Object

com.espertech.esper.epl.table.mgmt.TableServiceImpl

All Implemented Interfaces:

TableService

public class TableServiceImpl
extends java.lang.Object
implements TableService

Field Summary

Fields inherited from interface com.espertech.esper.epl.table.mgmt.TableService

INTERNAL_RESERVED_PROPERTY

Constructor Summary

Constructors

Constructor and Description
TableServiceImpl()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TableServiceImpl

public TableServiceImpl()

Method Detail

validateAddIndex

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

Specified by:

validateAddIndex in interface TableService

Throws:

ExprValidationException

getTableUpdateStrategy

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

Specified by:

getTableUpdateStrategy in interface TableService

Throws:

ExprValidationException

getAgentInstanceIds

public java.util.Collection<java.lang.Integer> getAgentInstanceIds(java.lang.String name)

Specified by:

getAgentInstanceIds in interface TableService

getTableExprEvaluatorContext

public TableExprEvaluatorContext getTableExprEvaluatorContext()

Specified by:

getTableExprEvaluatorContext in interface TableService

getTableMetadata

public TableMetadata getTableMetadata(java.lang.String tableName)

Specified by:

getTableMetadata in interface TableService

addTable

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

Specified by:

addTable in interface TableService

Throws:

ExprValidationException

removeTableIfFound

public void removeTableIfFound(java.lang.String tableName)

Specified by:

removeTableIfFound in interface TableService

getState

public TableStateInstance getState(java.lang.String name,
                                   int agentInstanceId)

Specified by:

getState in interface TableService

getQueryPlanLog

public static org.slf4j.Logger getQueryPlanLog()

getTableMetadataFromEventType

public TableMetadata getTableMetadataFromEventType(EventType type)

Specified by:

getTableMetadataFromEventType in interface TableService

getTableNodeChainable

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

Specified by:

getTableNodeChainable in interface TableService

Throws:

ExprValidationException

getTableIdentNode

public ExprTableIdentNode getTableIdentNode(StreamTypeService streamTypeService,
                                            java.lang.String unresolvedPropertyName,
                                            java.lang.String streamOrPropertyName)
                                     throws ExprValidationException

Specified by:

getTableIdentNode in interface TableService

Throws:

ExprValidationException

addTableUpdateStrategyReceiver

public void addTableUpdateStrategyReceiver(TableMetadata tableMetadata,
                                           java.lang.String statementName,
                                           TableUpdateStrategyReceiver receiver,
                                           EventBeanUpdateHelper updateHelper,
                                           boolean isOnMerge)

Specified by:

addTableUpdateStrategyReceiver in interface TableService

removeTableUpdateStrategyReceivers

public void removeTableUpdateStrategyReceivers(TableMetadata tableMetadata,
                                               java.lang.String statementName)

Specified by:

removeTableUpdateStrategyReceivers in interface TableService

getTables

public java.lang.String[] getTables()

Specified by:

getTables in interface TableService

getStateProvider

public TableAndLockProvider getStateProvider(java.lang.String tableName,
                                             int agentInstanceId,
                                             boolean writesToTables)

Specified by:

getStateProvider in interface TableService

removeIndexReferencesStmtMayRemoveIndex

public void removeIndexReferencesStmtMayRemoveIndex(java.lang.String statementName,
                                                    TableMetadata tableMetadata)

Specified by:

removeIndexReferencesStmtMayRemoveIndex in interface TableService