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

Class TableBase

java.lang.Object

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

All Implemented Interfaces:

Table

Direct Known Subclasses:

TableImpl

public abstract class TableBase
extends Object
implements Table

Field Summary

Fields

Modifier and Type	Field and Description
protected AggregationRowFactory	aggregationRowFactory
protected TableMetadataInternalEventToPublic	eventToPublic
protected TableMetaData	metaData
protected EventPropertyValueGetter	primaryKeyGetter
protected PropertyHashedEventTableFactory	primaryKeyIndexFactory
protected StatementContext	statementContextCreateTable
protected TableSerdes	tableSerdes
protected Set<TableUpdateStrategyRedoCallback>	updateStrategyRedoCallbacks

Constructor Summary

Constructors

Constructor and Description
TableBase(TableMetaData metaData)

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()
TableInstance	getTableInstanceNoContextNoRemake()
TableInstance	getTableInstanceNoRemake(int agentInstanceId)
TableSerdes	getTableSerdes()
Collection<TableUpdateStrategyRedoCallback>	getUpdateStrategyCallbacks()
boolean	isGrouped()
void	removeAllInstanceIndexes(IndexMultiKey index)
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)
protected abstract PropertyHashedEventTableFactory	setupPrimaryKeyIndexFactory()
void	tableReady()
void	validateAddIndex(String deploymentId, String statementName, String indexName, String indexModuleName, QueryPlanIndexItem explicitIndexDesc, IndexMultiKey indexMultiKey)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.common.internal.epl.table.core.Table

getStateProvider, getTableInstance, getTableInstanceNoContext

Field Detail

metaData

protected final TableMetaData metaData

eventToPublic

protected TableMetadataInternalEventToPublic eventToPublic

statementContextCreateTable

protected StatementContext statementContextCreateTable

aggregationRowFactory

protected AggregationRowFactory aggregationRowFactory

tableSerdes

protected TableSerdes tableSerdes

primaryKeyGetter

protected EventPropertyValueGetter primaryKeyGetter

updateStrategyRedoCallbacks

protected Set<TableUpdateStrategyRedoCallback> updateStrategyRedoCallbacks

primaryKeyIndexFactory

protected PropertyHashedEventTableFactory primaryKeyIndexFactory

Constructor Detail

TableBase

public TableBase(TableMetaData metaData)

Method Detail

setupPrimaryKeyIndexFactory

protected abstract PropertyHashedEventTableFactory setupPrimaryKeyIndexFactory()

setEventToPublic

public void setEventToPublic(TableMetadataInternalEventToPublic eventToPublic)

Specified by:

setEventToPublic in interface Table

setStatementContextCreateTable

public void setStatementContextCreateTable(StatementContext statementContextCreateTable)

Specified by:

setStatementContextCreateTable in interface Table

setAggregationRowFactory

public void setAggregationRowFactory(AggregationRowFactory aggregationRowFactory)

Specified by:

setAggregationRowFactory in interface Table

setTableSerdes

public void setTableSerdes(TableSerdes tableSerdes)

Specified by:

setTableSerdes in interface Table

setPrimaryKeyGetter

public void setPrimaryKeyGetter(EventPropertyValueGetter primaryKeyGetter)

Specified by:

setPrimaryKeyGetter in interface Table

tableReady

public void tableReady()

Specified by:

tableReady in interface Table

getEventToPublic

public TableMetadataInternalEventToPublic getEventToPublic()

Specified by:

getEventToPublic in interface Table

getMetaData

public TableMetaData getMetaData()

Specified by:

getMetaData in interface Table

getTableSerdes

public TableSerdes getTableSerdes()

Specified by:

getTableSerdes in interface Table

getAggregationRowFactory

public AggregationRowFactory getAggregationRowFactory()

Specified by:

getAggregationRowFactory in interface Table

getStatementContextCreateTable

public StatementContext getStatementContextCreateTable()

Specified by:

getStatementContextCreateTable in interface Table

getPrimaryIndexFactory

public PropertyHashedEventTableFactory getPrimaryIndexFactory()

Specified by:

getPrimaryIndexFactory in interface Table

isGrouped

public boolean isGrouped()

Specified by:

isGrouped in interface Table

getName

public String getName()

Specified by:

getName in interface Table

getEventTableIndexMetadata

public EventTableIndexMetadata getEventTableIndexMetadata()

Specified by:

getEventTableIndexMetadata in interface Table

getTableInstanceNoRemake

public TableInstance getTableInstanceNoRemake(int agentInstanceId)

getTableInstanceNoContextNoRemake

public TableInstance getTableInstanceNoContextNoRemake()

validateAddIndex

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

Specified by:

validateAddIndex in interface Table

Throws:

ExprValidationException

removeIndexReferencesStmtMayRemoveIndex

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

Specified by:

removeIndexReferencesStmtMayRemoveIndex in interface Table

removeAllInstanceIndexes

public void removeAllInstanceIndexes(IndexMultiKey index)

Specified by:

removeAllInstanceIndexes in interface Table

addUpdateStrategyCallback

public void addUpdateStrategyCallback(TableUpdateStrategyRedoCallback callback)

Specified by:

addUpdateStrategyCallback in interface Table

removeUpdateStrategyCallback

public void removeUpdateStrategyCallback(TableUpdateStrategyRedoCallback callback)

Specified by:

removeUpdateStrategyCallback in interface Table

getUpdateStrategyCallbacks

public Collection<TableUpdateStrategyRedoCallback> getUpdateStrategyCallbacks()

Specified by:

getUpdateStrategyCallbacks in interface Table