Package com.espertech.esper.common.internal.statemgmtsettings

Interface StateMgmtSettingsProvider

All Known Implementing Classes:

StateMgmtSettingsProviderDefault

public interface StateMgmtSettingsProvider

Method Summary

Modifier and Type	Method	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, Map<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)

Method Details

newCharge

FabricCharge newCharge()

spec

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

statement

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

context

StateMgmtSettingsProviderContext context()

resultSet

StateMgmtSettingsProviderResultSet resultSet()

index

StateMgmtSettingsProviderIndex index()

view

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

aggregation

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

rowRecogPartitionState

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

rowRecogScheduleState

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

previous

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

prior

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

tableUnkeyed

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

filterViewable

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

filterNonContext

void filterNonContext(FabricCharge fabricCharge,
 FilterSpecTracked spec)

filterSubtypes

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

pattern

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

namedWindow

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

table

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

inlinedClassesLocal

void inlinedClassesLocal(FabricCharge fabricCharge,
 ClassProvidedPrecompileResult classesInlined)

inlinedClasses

void inlinedClasses(FabricCharge fabricCharge,
 ClassProvided classProvided)

historicalExpiryTime

void historicalExpiryTime(FabricCharge fabricCharge,
 int streamNum)

schedules

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