com.espertech.esper.common.internal.context.mgr

Class ContextServiceFactoryDefault

java.lang.Object

com.espertech.esper.common.internal.context.mgr.ContextServiceFactoryDefault

All Implemented Interfaces:

ContextServiceFactory

public class ContextServiceFactoryDefault
extends Object
implements ContextServiceFactory

Field Summary

Fields

Modifier and Type	Field and Description
static ContextServiceFactoryDefault	INSTANCE

Method Summary

Modifier and Type	Method and Description
ContextControllerCategoryFactory	categoryFactory(StateMgmtSetting stateMgmtSettings)
ContextPartitionIdService	getContextPartitionIdService(StatementContext statementContextCreateContext, DataInputOutputSerde[] bindings, StateMgmtSetting stateMgmtSettings)
DataInputOutputSerde[]	getContextPartitionKeyBindings(ContextDefinition contextDefinition)
ContextStatementEventEvaluator	getContextStatementEventEvaluator()
ContextControllerHashFactory	hashFactory(StateMgmtSetting stateMgmtSettings)
ContextControllerInitTermFactory	initTermFactory(StateMgmtSetting distinctStateMgmtSettings, StateMgmtSetting ctxStateMgmtSettings)
ContextControllerKeyedFactory	keyedFactory(StateMgmtSetting terminationStateMgmtSettings, StateMgmtSetting ctxStateMgmtSettings)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final ContextServiceFactoryDefault INSTANCE

Method Detail

keyedFactory

public ContextControllerKeyedFactory keyedFactory(StateMgmtSetting terminationStateMgmtSettings,
                                                  StateMgmtSetting ctxStateMgmtSettings)

Specified by:

keyedFactory in interface ContextServiceFactory

categoryFactory

public ContextControllerCategoryFactory categoryFactory(StateMgmtSetting stateMgmtSettings)

Specified by:

categoryFactory in interface ContextServiceFactory

hashFactory

public ContextControllerHashFactory hashFactory(StateMgmtSetting stateMgmtSettings)

Specified by:

hashFactory in interface ContextServiceFactory

initTermFactory

public ContextControllerInitTermFactory initTermFactory(StateMgmtSetting distinctStateMgmtSettings,
                                                        StateMgmtSetting ctxStateMgmtSettings)

Specified by:

initTermFactory in interface ContextServiceFactory

getContextPartitionKeyBindings

public DataInputOutputSerde[] getContextPartitionKeyBindings(ContextDefinition contextDefinition)

Specified by:

getContextPartitionKeyBindings in interface ContextServiceFactory

getContextPartitionIdService

public ContextPartitionIdService getContextPartitionIdService(StatementContext statementContextCreateContext,
                                                              DataInputOutputSerde[] bindings,
                                                              StateMgmtSetting stateMgmtSettings)

Specified by:

getContextPartitionIdService in interface ContextServiceFactory

getContextStatementEventEvaluator

public ContextStatementEventEvaluator getContextStatementEventEvaluator()

Specified by:

getContextStatementEventEvaluator in interface ContextServiceFactory