Package com.espertech.esper.common.internal.epl.lookupplansubord

Class SubordinateQueryPlannerUtil

java.lang.Object

com.espertech.esper.common.internal.epl.lookupplansubord.SubordinateQueryPlannerUtil

public class SubordinateQueryPlannerUtil
extends Object

Constructor Summary

Constructors

Constructor	Description
SubordinateQueryPlannerUtil()

Method Summary

Modifier and Type	Method	Description
static void	addIndexMetaAndRef(SubordinateQueryIndexDesc[] indexDescs, EventTableIndexMetadata repo, String deploymentId, String statementName)
static IndexKeyInfo	compileIndexKeyInfo(IndexMultiKey indexMultiKey, String[] hashIndexPropsProvided, SubordPropHashKeyForge[] hashJoinedProps, String[] rangeIndexPropsProvided, SubordPropRangeKeyForge[] rangeJoinedProps)	Given an index with a defined set of hash(equals) and range(btree) props and uniqueness flag, and given a list of indexable properties and accessAccessors for both hash and range, return the ordered keys and coercion information.
static void	queryPlanLogOnExpr(boolean queryPlanLogging, org.slf4j.Logger queryPlanLog, SubordinateWMatchExprQueryPlanForge strategy, Annotation[] annotations, ClasspathImportService classpathImportService)
static void	queryPlanLogOnSubq(boolean queryPlanLogging, org.slf4j.Logger queryPlanLog, SubordinateQueryPlanDescForge plan, int subqueryNum, Annotation[] annotations, ClasspathImportService classpathImportService)
static EventTable[]	realizeTables(SubordinateQueryIndexDesc[] indexDescriptors, EventType eventType, EventTableIndexRepository indexRepository, Iterable<EventBean> contents, AgentInstanceContext agentInstanceContext, boolean isRecoveringResilient)
static SubordinateQueryPlannerIndexPropListPair	toListOfHashedAndBtreeProps(String[] hashIndexPropsProvided, EPTypeClass[] hashIndexCoercionType, String[] rangeIndexPropsProvided, EPTypeClass[] rangeIndexCoercionType)

Methods inherited from class java.lang.Object

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

Constructor Details

SubordinateQueryPlannerUtil

public SubordinateQueryPlannerUtil()

Method Details

toListOfHashedAndBtreeProps

public static SubordinateQueryPlannerIndexPropListPair toListOfHashedAndBtreeProps(String[] hashIndexPropsProvided,
 EPTypeClass[] hashIndexCoercionType,
 String[] rangeIndexPropsProvided,
 EPTypeClass[] rangeIndexCoercionType)

queryPlanLogOnExpr

public static void queryPlanLogOnExpr(boolean queryPlanLogging,
 org.slf4j.Logger queryPlanLog,
 SubordinateWMatchExprQueryPlanForge strategy,
 Annotation[] annotations,
 ClasspathImportService classpathImportService)

queryPlanLogOnSubq

public static void queryPlanLogOnSubq(boolean queryPlanLogging,
 org.slf4j.Logger queryPlanLog,
 SubordinateQueryPlanDescForge plan,
 int subqueryNum,
 Annotation[] annotations,
 ClasspathImportService classpathImportService)

compileIndexKeyInfo

public static IndexKeyInfo compileIndexKeyInfo(IndexMultiKey indexMultiKey,
 String[] hashIndexPropsProvided,
 SubordPropHashKeyForge[] hashJoinedProps,
 String[] rangeIndexPropsProvided,
 SubordPropRangeKeyForge[] rangeJoinedProps)

Given an index with a defined set of hash(equals) and range(btree) props and uniqueness flag, and given a list of indexable properties and accessAccessors for both hash and range, return the ordered keys and coercion information.

Parameters:

indexMultiKey - index definition

hashIndexPropsProvided - hash indexable properties

hashJoinedProps - keys for hash indexable properties

rangeIndexPropsProvided - btree indexable properties

rangeJoinedProps - keys for btree indexable properties

Returns:

ordered set of key information

realizeTables

public static EventTable[] realizeTables(SubordinateQueryIndexDesc[] indexDescriptors,
 EventType eventType,
 EventTableIndexRepository indexRepository,
 Iterable<EventBean> contents,
 AgentInstanceContext agentInstanceContext,
 boolean isRecoveringResilient)

addIndexMetaAndRef

public static void addIndexMetaAndRef(SubordinateQueryIndexDesc[] indexDescs,
 EventTableIndexMetadata repo,
 String deploymentId,
 String statementName)