Package 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	Description
protected AggregationRowFactory	aggregationRowFactory
protected TableMetadataInternalEventToPublic	eventToPublic
protected final TableMetaData	metaData
protected EventPropertyValueGetter	primaryKeyGetter
protected PropertyHashedEventTableFactory	primaryKeyIndexFactory
protected MultiKeyFromMultiKey	primaryKeyIntoTableTransform
protected MultiKeyFromObjectArray	primaryKeyObjectArrayTransform
protected DataInputOutputSerde	primaryKeySerde
protected StatementContext	statementContextCreateTable
protected TableSerdes	tableSerdes
protected Set<TableUpdateStrategyRedoCallback>	updateStrategyRedoCallbacks

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

EPTYPE

Constructor Summary

Constructors

Constructor	Description
TableBase(TableMetaData metaData)

Method Summary

Modifier and Type	Method	Description
void	addUpdateStrategyCallback(TableUpdateStrategyRedoCallback callback)
AggregationRowFactory	getAggregationRowFactory()
EventTableIndexMetadata	getEventTableIndexMetadata()
TableMetadataInternalEventToPublic	getEventToPublic()
TableMetaData	getMetaData()
String	getName()
PropertyHashedEventTableFactory	getPrimaryIndexFactory()
MultiKeyFromMultiKey	getPrimaryKeyIntoTableTransform()
MultiKeyFromObjectArray	getPrimaryKeyObjectArrayTransform()
DataInputOutputSerde	getPrimaryKeySerde()
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	setPrimaryKeyIntoTableTransform(MultiKeyFromMultiKey primaryKeyIntoTableTransform)
void	setPrimaryKeyObjectArrayTransform(MultiKeyFromObjectArray primaryKeyObjectArrayTransform)
void	setPrimaryKeySerde(DataInputOutputSerde primaryKeySerde)
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 Details

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

primaryKeySerde

protected DataInputOutputSerde primaryKeySerde

primaryKeyObjectArrayTransform

protected MultiKeyFromObjectArray primaryKeyObjectArrayTransform

primaryKeyIntoTableTransform

protected MultiKeyFromMultiKey primaryKeyIntoTableTransform

updateStrategyRedoCallbacks

protected Set<TableUpdateStrategyRedoCallback> updateStrategyRedoCallbacks

primaryKeyIndexFactory

protected PropertyHashedEventTableFactory primaryKeyIndexFactory

Constructor Details

TableBase

public TableBase(TableMetaData metaData)

Method Details

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

setPrimaryKeySerde

public void setPrimaryKeySerde(DataInputOutputSerde primaryKeySerde)

Specified by:

setPrimaryKeySerde in interface Table

setPrimaryKeyObjectArrayTransform

public void setPrimaryKeyObjectArrayTransform(MultiKeyFromObjectArray primaryKeyObjectArrayTransform)

Specified by:

setPrimaryKeyObjectArrayTransform in interface Table

setPrimaryKeyIntoTableTransform

public void setPrimaryKeyIntoTableTransform(MultiKeyFromMultiKey primaryKeyIntoTableTransform)

Specified by:

setPrimaryKeyIntoTableTransform 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

getPrimaryKeyIntoTableTransform

public MultiKeyFromMultiKey getPrimaryKeyIntoTableTransform()

Specified by:

getPrimaryKeyIntoTableTransform in interface Table

getPrimaryKeyObjectArrayTransform

public MultiKeyFromObjectArray getPrimaryKeyObjectArrayTransform()

Specified by:

getPrimaryKeyObjectArrayTransform in interface Table

getPrimaryKeySerde

public DataInputOutputSerde getPrimaryKeySerde()

Specified by:

getPrimaryKeySerde in interface Table