com.espertech.esper.common.internal.statemgmtsettings

Class StateMgmtSettingsProviderDefault

java.lang.Object

com.espertech.esper.common.internal.statemgmtsettings.StateMgmtSettingsProviderDefault

All Implemented Interfaces:

StateMgmtSettingsProvider

public class StateMgmtSettingsProviderDefault
extends Object
implements StateMgmtSettingsProvider

Field Summary

Fields

Modifier and Type	Field and Description
static StateMgmtSettingsProviderDefault	INSTANCE

Method Summary

Modifier and Type	Method and Description
StateMgmtSetting	aggregation(FabricCharge fabricCharge, AggregationAttributionKey attributionKey, StatementRawInfo raw, AggregationServiceFactoryForge forge)
StateMgmtSettingsProviderContext	context()
void	filterNonContext(FabricCharge fabricCharge, FilterSpecTracked spec)
void	filterSubtypes(FabricCharge fabricCharge, List<FilterSpecTracked> provider, ContextCompileTimeDescriptor contextDescriptor, StatementSpecCompiled compiled)
void	filterViewable(FabricCharge fabricCharge, int stream, boolean isCanIterateUnbound, StatementRawInfo statementRawInfo, EventType eventType)
void	historicalExpiryTime(FabricCharge fabricCharge, int streamNum)
StateMgmtSettingsProviderIndex	index()
void	inlinedClasses(FabricCharge fabricCharge, ClassProvided classProvided)
void	inlinedClassesLocal(FabricCharge fabricCharge, ClassProvidedPrecompileResult classesInlined)
void	namedWindow(FabricCharge fabricCharge, StatementRawInfo statementRawInfo, NamedWindowMetaData metaData, EventType eventType)
FabricCharge	newCharge()
void	pattern(FabricCharge fabricCharge, PatternAttributionKey attributionKey, PatternStreamSpecCompiled patternStreamSpec, StatementRawInfo raw)
StateMgmtSetting	previous(FabricCharge fabricCharge, StatementRawInfo raw, int stream, Integer subqueryNumber, EventType eventType)
StateMgmtSetting	prior(FabricCharge fabricCharge, StatementRawInfo raw, int streamNum, Integer subqueryNumber, boolean unbound, EventType eventType, SortedSet<Integer> priorRequesteds)
StateMgmtSettingsProviderResultSet	resultSet()
StateMgmtSetting	rowRecogPartitionState(FabricCharge fabricCharge, StatementRawInfo raw, RowRecogDescForge forge, MatchRecognizeSpec spec)
StateMgmtSetting	rowRecogScheduleState(FabricCharge fabricCharge, StatementRawInfo raw, RowRecogDescForge forge, MatchRecognizeSpec spec)
void	schedules(FabricCharge fabricCharge, List<ScheduleHandleTracked> trackeds)
void	spec(List<FabricStatement> formatStatements, ModuleCompileTimeServices compileTimeServices, ConcurrentHashMap<String,byte[]> moduleBytes)
FabricStatement	statement(int statementNumber, ContextCompileTimeDescriptor context, FabricCharge fabricCharge)
void	table(FabricCharge fabricCharge, String tableName, TableAccessAnalysisResult plan, StatementRawInfo statementRawInfo)
StateMgmtSetting	tableUnkeyed(FabricCharge fabricCharge, String tableName, TableAccessAnalysisResult tableInternalType, StatementRawInfo statementRawInfo)
StateMgmtSetting	view(FabricCharge fabricCharge, int[] grouping, ViewForgeEnv viewForgeEnv, ViewFactoryForge forge)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final StateMgmtSettingsProviderDefault INSTANCE

Method Detail

newCharge

public FabricCharge newCharge()

Specified by:

newCharge in interface StateMgmtSettingsProvider

view

public StateMgmtSetting view(FabricCharge fabricCharge,
                             int[] grouping,
                             ViewForgeEnv viewForgeEnv,
                             ViewFactoryForge forge)

Specified by:

view in interface StateMgmtSettingsProvider

context

public StateMgmtSettingsProviderContext context()

Specified by:

context in interface StateMgmtSettingsProvider

resultSet

public StateMgmtSettingsProviderResultSet resultSet()

Specified by:

resultSet in interface StateMgmtSettingsProvider

index

public StateMgmtSettingsProviderIndex index()

Specified by:

index in interface StateMgmtSettingsProvider

aggregation

public StateMgmtSetting aggregation(FabricCharge fabricCharge,
                                    AggregationAttributionKey attributionKey,
                                    StatementRawInfo raw,
                                    AggregationServiceFactoryForge forge)

Specified by:

aggregation in interface StateMgmtSettingsProvider

previous

public StateMgmtSetting previous(FabricCharge fabricCharge,
                                 StatementRawInfo raw,
                                 int stream,
                                 Integer subqueryNumber,
                                 EventType eventType)

Specified by:

previous in interface StateMgmtSettingsProvider

prior

public StateMgmtSetting prior(FabricCharge fabricCharge,
                              StatementRawInfo raw,
                              int streamNum,
                              Integer subqueryNumber,
                              boolean unbound,
                              EventType eventType,
                              SortedSet<Integer> priorRequesteds)

Specified by:

prior in interface StateMgmtSettingsProvider

rowRecogPartitionState

public StateMgmtSetting rowRecogPartitionState(FabricCharge fabricCharge,
                                               StatementRawInfo raw,
                                               RowRecogDescForge forge,
                                               MatchRecognizeSpec spec)

Specified by:

rowRecogPartitionState in interface StateMgmtSettingsProvider

rowRecogScheduleState

public StateMgmtSetting rowRecogScheduleState(FabricCharge fabricCharge,
                                              StatementRawInfo raw,
                                              RowRecogDescForge forge,
                                              MatchRecognizeSpec spec)

Specified by:

rowRecogScheduleState in interface StateMgmtSettingsProvider

tableUnkeyed

public StateMgmtSetting tableUnkeyed(FabricCharge fabricCharge,
                                     String tableName,
                                     TableAccessAnalysisResult tableInternalType,
                                     StatementRawInfo statementRawInfo)

Specified by:

tableUnkeyed in interface StateMgmtSettingsProvider

spec

public void spec(List<FabricStatement> formatStatements,
                 ModuleCompileTimeServices compileTimeServices,
                 ConcurrentHashMap<String,byte[]> moduleBytes)

Specified by:

spec in interface StateMgmtSettingsProvider

statement

public FabricStatement statement(int statementNumber,
                                 ContextCompileTimeDescriptor context,
                                 FabricCharge fabricCharge)

Specified by:

statement in interface StateMgmtSettingsProvider

filterViewable

public void filterViewable(FabricCharge fabricCharge,
                           int stream,
                           boolean isCanIterateUnbound,
                           StatementRawInfo statementRawInfo,
                           EventType eventType)

Specified by:

filterViewable in interface StateMgmtSettingsProvider

filterNonContext

public void filterNonContext(FabricCharge fabricCharge,
                             FilterSpecTracked spec)

Specified by:

filterNonContext in interface StateMgmtSettingsProvider

namedWindow

public void namedWindow(FabricCharge fabricCharge,
                        StatementRawInfo statementRawInfo,
                        NamedWindowMetaData metaData,
                        EventType eventType)

Specified by:

namedWindow in interface StateMgmtSettingsProvider

table

public void table(FabricCharge fabricCharge,
                  String tableName,
                  TableAccessAnalysisResult plan,
                  StatementRawInfo statementRawInfo)

Specified by:

table in interface StateMgmtSettingsProvider

pattern

public void pattern(FabricCharge fabricCharge,
                    PatternAttributionKey attributionKey,
                    PatternStreamSpecCompiled patternStreamSpec,
                    StatementRawInfo raw)

Specified by:

pattern in interface StateMgmtSettingsProvider

inlinedClassesLocal

public void inlinedClassesLocal(FabricCharge fabricCharge,
                                ClassProvidedPrecompileResult classesInlined)

Specified by:

inlinedClassesLocal in interface StateMgmtSettingsProvider

inlinedClasses

public void inlinedClasses(FabricCharge fabricCharge,
                           ClassProvided classProvided)

Specified by:

inlinedClasses in interface StateMgmtSettingsProvider

filterSubtypes

public void filterSubtypes(FabricCharge fabricCharge,
                           List<FilterSpecTracked> provider,
                           ContextCompileTimeDescriptor contextDescriptor,
                           StatementSpecCompiled compiled)

Specified by:

filterSubtypes in interface StateMgmtSettingsProvider

historicalExpiryTime

public void historicalExpiryTime(FabricCharge fabricCharge,
                                 int streamNum)

Specified by:

historicalExpiryTime in interface StateMgmtSettingsProvider

schedules

public void schedules(FabricCharge fabricCharge,
                      List<ScheduleHandleTracked> trackeds)

Specified by:

schedules in interface StateMgmtSettingsProvider