com.espertech.esper.epl.table.mgmt

Class TableMetadata

java.lang.Object

com.espertech.esper.epl.table.mgmt.TableMetadata

public class TableMetadata
extends Object

Constructor Summary

Constructors

Constructor and Description

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

Method Summary

Modifier and Type	Method and Description
void	addIndexReference(String indexName, String statementName)
void	addTableUpdateStrategyReceiver(String statementName, TableUpdateStrategyReceiver receiver, EventBeanUpdateHelper updateHelper, boolean onMerge)
void	clearTableInstances()
Collection<Integer>	getAgentInstanceIds()
String	getContextName()
String	getEplExpression()
EventTableIndexMetadata	getEventTableIndexMetadataRepo()
TableMetadataInternalEventToPublic	getEventToPublic()
ObjectArrayEventType	getInternalEventType()
Class[]	getKeyTypes()
int	getNumberMethodAggregations()
EventBean	getPublicEventBean(EventBean event, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
EventType	getPublicEventType()
TableStateRowFactory	getRowFactory()
TableStateInstance	getState(int agentInstanceId)
StatementContext	getStatementContextCreateTable()
String	getStatementName()
Map<String,TableMetadataColumn>	getTableColumns()
TableMetadataContext	getTableMetadataContext()
String	getTableName()
TableRowKeyFactory	getTableRowKeyFactory()
TableStateFactory	getTableStateFactory()
String[][]	getUniqueIndexes()
Set<String>	getUniqueKeyProps()
boolean	isQueryPlanLogging()
void	removeIndexReferencesStatement(String statementName)
void	removeTableUpdateStrategyReceivers(String statementName)
void	setTableMetadataContext(TableMetadataContext tableMetadataContext)
void	setTableStateFactory(TableStateFactory tableStateFactory)
void	validateAddIndexAssignUpdateStrategies(String createIndexStatementName, IndexMultiKey imk, String explicitIndexName, QueryPlanIndexItem explicitIndexDesc)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableMetadata

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

Throws:

ExprValidationException

Method Detail

getKeyTypes

public Class[] getKeyTypes()

getTableStateFactory

public TableStateFactory getTableStateFactory()

getTableColumns

public Map<String,TableMetadataColumn> getTableColumns()

getRowFactory

public TableStateRowFactory getRowFactory()

getNumberMethodAggregations

public int getNumberMethodAggregations()

getContextName

public String getContextName()

getInternalEventType

public ObjectArrayEventType getInternalEventType()

isQueryPlanLogging

public boolean isQueryPlanLogging()

getUniqueKeyProps

public Set<String> getUniqueKeyProps()

setTableStateFactory

public void setTableStateFactory(TableStateFactory tableStateFactory)

getTableName

public String getTableName()

getEventTableIndexMetadataRepo

public EventTableIndexMetadata getEventTableIndexMetadataRepo()

getPublicEventBean

public EventBean getPublicEventBean(EventBean event,
                                    EventBean[] eventsPerStream,
                                    boolean isNewData,
                                    ExprEvaluatorContext context)

getPublicEventType

public EventType getPublicEventType()

getEventToPublic

public TableMetadataInternalEventToPublic getEventToPublic()

validateAddIndexAssignUpdateStrategies

public void validateAddIndexAssignUpdateStrategies(String createIndexStatementName,
                                                   IndexMultiKey imk,
                                                   String explicitIndexName,
                                                   QueryPlanIndexItem explicitIndexDesc)
                                            throws ExprValidationException

Throws:

ExprValidationException

addTableUpdateStrategyReceiver

public void addTableUpdateStrategyReceiver(String statementName,
                                           TableUpdateStrategyReceiver receiver,
                                           EventBeanUpdateHelper updateHelper,
                                           boolean onMerge)

removeTableUpdateStrategyReceivers

public void removeTableUpdateStrategyReceivers(String statementName)

addIndexReference

public void addIndexReference(String indexName,
                              String statementName)

removeIndexReferencesStatement

public void removeIndexReferencesStatement(String statementName)

getState

public TableStateInstance getState(int agentInstanceId)

getAgentInstanceIds

public Collection<Integer> getAgentInstanceIds()

getUniqueIndexes

public String[][] getUniqueIndexes()

setTableMetadataContext

public void setTableMetadataContext(TableMetadataContext tableMetadataContext)

getTableMetadataContext

public TableMetadataContext getTableMetadataContext()

getTableRowKeyFactory

public TableRowKeyFactory getTableRowKeyFactory()

clearTableInstances

public void clearTableInstances()

getEplExpression

public String getEplExpression()

getStatementName

public String getStatementName()

getStatementContextCreateTable

public StatementContext getStatementContextCreateTable()