Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
StateMgmtIndexDescInSingle.getMultiKeyPlan() |
MultiKeyClassRef |
StateMgmtIndexDescHash.getMultiKeyPlan() |
MultiKeyClassRef |
StateMgmtIndexDescComposite.getMultiKeyPlan() |
Constructor and Description |
---|
StateMgmtIndexDescComposite(String[] indexedProps,
MultiKeyClassRef multiKeyPlan,
String[] indexedRangeProps,
DataInputOutputSerdeForge[] rangeSerdes) |
StateMgmtIndexDescHash(String[] indexedProps,
MultiKeyClassRef multiKeyPlan,
boolean unique) |
StateMgmtIndexDescInSingle(String indexedProp,
MultiKeyClassRef multiKeyPlan) |
Modifier and Type | Class and Description |
---|---|
class |
MultiKeyClassRefEmpty |
class |
MultiKeyClassRefPredetermined |
class |
MultiKeyClassRefUUIDBased |
class |
MultiKeyClassRefWSerde |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
MultiKeyPlan.getClassRef() |
Constructor and Description |
---|
MultiKeyPlan(List<StmtClassForgeableFactory> multiKeyForgeables,
MultiKeyClassRef classRef) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
ContextSpecInitiatedTerminated.getDistinctMultiKey() |
MultiKeyClassRef |
ContextSpecKeyedItem.getKeyMultiKey() |
Modifier and Type | Method and Description |
---|---|
void |
ContextSpecInitiatedTerminated.setDistinctMultiKey(MultiKeyClassRef distinctMultiKey) |
void |
ContextSpecKeyedItem.setKeyMultiKey(MultiKeyClassRef keyMultiKey) |
void |
ContextSpecKeyed.setMultiKeyClassRef(MultiKeyClassRef multiKeyClassRef) |
Constructor and Description |
---|
StatementAgentInstanceFactoryOnTriggerInfraSelectForge(ViewableActivatorForge activator,
EventType resultEventType,
Map<ExprSubselectNode,SubSelectFactoryForge> subselects,
Map<ExprTableAccessNode,ExprTableEvalStrategyFactoryForge> tableAccesses,
NamedWindowMetaData namedWindow,
TableMetaData table,
SubordinateWMatchExprQueryPlanForge queryPlanForge,
String resultSetProcessorProviderClassName,
boolean insertInto,
boolean addToFront,
TableMetaData optionalInsertIntoTable,
boolean selectAndDelete,
boolean distinct,
MultiKeyClassRef distinctMultiKey) |
Constructor and Description |
---|
StatementInformationalsCompileTime(String statementNameCompileTime,
boolean alwaysSynthesizeOutputEvents,
String optionalContextName,
String optionalContextModuleName,
NameAccessModifier optionalContextVisibility,
boolean canSelfJoin,
boolean hasSubquery,
boolean needDedup,
Annotation[] annotations,
boolean stateless,
Serializable userObjectCompileTime,
int numFilterCallbacks,
int numScheduleCallbacks,
int numNamedWindowCallbacks,
StatementType statementType,
int priority,
boolean preemptive,
boolean hasVariables,
boolean writesToTables,
boolean hasTableAccess,
Class[] selectClauseTypes,
String[] selectClauseColumnNames,
boolean forClauseDelivery,
ExprNode[] groupDelivery,
MultiKeyClassRef groupDeliveryMultiKey,
Map<StatementProperty,Object> properties,
boolean hasMatchRecognize,
boolean instrumented,
CodegenPackageScope packageScope,
String insertIntoLatchName,
boolean allowSubscriber,
ExpressionScriptProvided[] onScripts) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
AggregationGroupByRollupLevelForge.getAllKeysMultikey() |
MultiKeyClassRef |
AggregationCodegenRowDetailDesc.getMultiKeyClassRef() |
MultiKeyClassRef |
AggregationGroupByRollupLevelForge.getSubKeyMultikey() |
Modifier and Type | Method and Description |
---|---|
static CodegenMethod |
AggregationServiceCodegenUtil.computeMultiKeyCodegen(int idNumber,
ExprNode[] partitionForges,
MultiKeyClassRef optionalMultiKey,
CodegenClassScope classScope,
CodegenNamedMethods namedMethods) |
static AggregationServiceForgeDesc |
AggregationServiceFactoryFactory.getService(AggregationAttributionKey attributionKey,
List<ExprAggregateNode> selectAggregateExprNodes,
Map<ExprNode,String> selectClauseNamedNodes,
List<ExprDeclaredNode> declaredExpressions,
ExprNode[] groupByNodes,
MultiKeyClassRef groupByMultiKey,
List<ExprAggregateNode> havingAggregateExprNodes,
List<ExprAggregateNode> orderByAggregateExprNodes,
List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
Annotation[] annotations,
VariableCompileTimeResolver variableCompileTimeResolver,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
EventType[] typesPerStream,
AggregationGroupByRollupDescForge groupByRollupDesc,
String optionalContextName,
IntoTableSpec intoTableSpec,
TableCompileTimeResolver tableCompileTimeResolver,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
ClasspathImportServiceCompileTime classpathImportService,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver,
StateMgmtSettingsProvider stateMgmtSettingsProvider) |
Constructor and Description |
---|
AggregationCodegenRowDetailDesc(AggregationCodegenRowDetailStateDesc stateDesc,
AggregationAccessorSlotPairForge[] accessAccessors,
MultiKeyClassRef multiKeyClassRef) |
AggregationGroupByRollupLevelForge(int levelNumber,
int levelOffset,
int[] rollupKeys,
EPType[] allGroupKeyTypes,
MultiKeyClassRef allKeysMultikey,
MultiKeyClassRef subKeyMultikey) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
AggGroupByDesc.getGroupByMultiKey() |
Constructor and Description |
---|
AggGroupByDesc(AggregationRowStateForgeDesc rowStateForgeDescs,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
ExprNode[] groupByNodes,
MultiKeyClassRef groupByMultiKey) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
AggregationLocalGroupByLevelForge.getPartitionMKClasses() |
Modifier and Type | Method and Description |
---|---|
static AggregationLocalGroupByPlanDesc |
AggregationGroupByLocalGroupByAnalyzer.analyze(ExprForge[][] methodForges,
AggregationForgeFactory[] methodFactories,
AggregationStateFactoryForge[] accessAggregations,
AggregationGroupByLocalGroupDesc localGroupDesc,
ExprNode[] groupByExpressions,
MultiKeyClassRef groupByMultiKey,
AggregationAccessorSlotPairForge[] accessors,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver) |
Constructor and Description |
---|
AggregationLocalGroupByLevelForge(ExprForge[][] methodForges,
AggregationForgeFactory[] methodFactories,
AggregationStateFactoryForge[] accessStateForges,
ExprNode[] partitionForges,
MultiKeyClassRef partitionMKClasses,
boolean defaultLevel) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
FAFQueryMethodSelectDesc.getDistinctMultiKey() |
Modifier and Type | Field and Description |
---|---|
protected MultiKeyClassRef |
HistoricalEventViewableForgeBase.multiKeyClassRef |
Constructor and Description |
---|
PollResultIndexingStrategyCompositeForge(int streamNum,
EventType eventType,
String[] optHashPropertyNames,
EPTypeClass[] optHashCoercedTypes,
MultiKeyClassRef optHashMultiKeyClasses,
String[] rangeProps,
EPTypeClass[] rangeTypes) |
PollResultIndexingStrategyHashForge(int streamNum,
EventType eventType,
String[] propertyNames,
EPTypeClass[] coercionTypes,
MultiKeyClassRef multiKeyClasses) |
Constructor and Description |
---|
HistoricalIndexLookupStrategyCompositeForge(int lookupStream,
ExprForge[] evaluators,
MultiKeyClassRef multiKeyClasses,
QueryGraphValueEntryRangeForge[] ranges) |
HistoricalIndexLookupStrategyHashForge(int lookupStream,
ExprForge[] evaluators,
EPTypeClass[] coercionTypes,
MultiKeyClassRef multiKeyClassRef) |
Constructor and Description |
---|
PropertyCompositeEventTableFactoryFactoryForge(int indexedStreamNum,
Integer subqueryNum,
boolean isFireAndForget,
String[] optKeyProps,
EPTypeClass[] optKeyTypes,
MultiKeyClassRef hashMultikeyClasses,
String[] rangeProps,
EPTypeClass[] rangeTypes,
DataInputOutputSerdeForge[] rangeSerdes,
EventType eventType) |
Constructor and Description |
---|
PropertyHashedFactoryFactoryForge(int indexedStreamNum,
Integer subqueryNum,
boolean isFireAndForget,
String[] indexedProps,
EventType eventType,
boolean unique,
CoercionDesc hashCoercionDesc,
MultiKeyClassRef multiKeyClassRef,
StateMgmtSetting stateMgmtSettings) |
Constructor and Description |
---|
CompositeTableLookupPlanForge(int lookupStream,
int indexedStream,
boolean indexedStreamIsVDW,
EventType[] typesPerStream,
TableLookupIndexReqKey indexNum,
List<QueryGraphValueEntryHashKeyedForge> hashKeys,
EPTypeClass[] hashCoercionTypes,
List<QueryGraphValueEntryRangeForge> rangeKeyPairs,
EPTypeClass[] optRangeCoercionTypes,
QueryPlanIndexForge indexSpecs,
MultiKeyClassRef optionalEPLTableLookupMultiKey) |
IndexedTableLookupPlanHashedOnlyForge(int lookupStream,
int indexedStream,
boolean indexedStreamIsVDW,
EventType[] typesPerStream,
TableLookupIndexReqKey indexNum,
QueryGraphValueEntryHashKeyedForge[] hashKeys,
QueryPlanIndexForge indexSpecs,
EPTypeClass[] optionalCoercionTypes,
MultiKeyClassRef optionalEPLTableLookupMultiKey) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
QueryPlanIndexItemForge.getHashMultiKeyClasses() |
Modifier and Type | Method and Description |
---|---|
void |
QueryPlanIndexItemForge.setHashMultiKeyClasses(MultiKeyClassRef hashMultiKeyClasses) |
Constructor and Description |
---|
SubordCompositeTableLookupStrategyFactoryForge(boolean isNWOnTrigger,
int numStreams,
List<SubordPropHashKeyForge> keyExpr,
EPTypeClass[] coercionKeyTypes,
MultiKeyClassRef hashMultikeyClasses,
List<SubordPropRangeKeyForge> rangeProps,
EPTypeClass[] coercionRangeTypes) |
SubordHashedTableLookupStrategyFactoryForge(boolean isNWOnTrigger,
int numStreamsOuter,
List<SubordPropHashKeyForge> hashKeys,
CoercionDesc hashKeyCoercionTypes,
boolean isStrictKeys,
String[] hashStrictKeys,
int[] keyStreamNumbers,
EventType[] outerStreamTypesZeroIndexed,
MultiKeyClassRef hashMultikeyClasses) |
Modifier and Type | Method and Description |
---|---|
static SubordTableLookupStrategyFactoryForge |
SubordinateTableLookupStrategyUtil.getLookupStrategy(EventType[] outerStreamTypesZeroIndexed,
List<SubordPropHashKeyForge> hashKeys,
CoercionDesc hashKeyCoercionTypes,
MultiKeyClassRef hashMultikeyClasses,
List<SubordPropRangeKeyForge> rangeKeys,
CoercionDesc rangeKeyCoercionTypes,
ExprNode[] inKeywordSingleIdxKeys,
ExprNode inKeywordMultiIdxKey,
boolean isNWOnTrigger) |
Constructor and Description |
---|
OutputProcessViewConditionForge(OutputStrategyPostProcessForge outputStrategyPostProcessForge,
boolean isDistinct,
MultiKeyClassRef distinctMultiKey,
ExprTimePeriod afterTimePeriodExpr,
Integer afterNumberOfEvents,
OutputConditionFactoryForge outputConditionFactoryForge,
int streamCount,
ResultSetProcessorOutputConditionType conditionType,
boolean terminable,
boolean hasAfter,
boolean unaggregatedUngrouped,
SelectClauseStreamSelectorEnum selectClauseStreamSelector,
EventType[] eventTypes,
EventType resultEventType,
StateMgmtSetting changeSetStateMgmtSettings,
StateMgmtSetting outputFirstStateMgmtSettings) |
OutputProcessViewDirectDistinctOrAfterFactoryForge(OutputStrategyPostProcessForge outputStrategyPostProcessForge,
boolean isDistinct,
MultiKeyClassRef distinctMultiKey,
ExprTimePeriod afterTimePeriod,
Integer afterConditionNumberOfEvents,
EventType resultEventType) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
EvalEveryDistinctForgeNode.getDistinctMultiKey() |
Modifier and Type | Method and Description |
---|---|
void |
EvalEveryDistinctForgeNode.setDistinctExpressions(List<ExprNode> distinctExpressions,
MultiKeyClassRef distincMultiKey,
TimePeriodComputeForge timePeriodComputeForge,
ExprNode expiryTimeExp) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
ResultSetProcessorAggregateGroupedForge.getMultiKeyClassRef() |
Constructor and Description |
---|
ResultSetProcessorAggregateGroupedForge(EventType resultEventType,
EventType[] typesPerStream,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorOutputConditionType outputConditionType,
OutputConditionPolledFactoryForge optionalOutputFirstConditionFactory,
MultiKeyClassRef multiKeyClassRef) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
GroupByRollupInfo.getOptionalMultiKey() |
Constructor and Description |
---|
GroupByRollupInfo(ExprNode[] exprNodes,
AggregationGroupByRollupDescForge rollupDesc,
List<StmtClassForgeableFactory> additionalForgeables,
MultiKeyClassRef optionalMultiKey) |
Modifier and Type | Method and Description |
---|---|
static CodegenMethod |
ResultSetProcessorGroupedUtil.generateGroupKeySingleCodegen(ExprNode[] groupKeyExpressions,
MultiKeyClassRef optionalMultiKeyClasses,
CodegenClassScope classScope,
CodegenInstanceAux instance) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
ResultSetProcessorRowPerGroupForge.getMultiKeyClassRef() |
Constructor and Description |
---|
ResultSetProcessorRowPerGroupForge(EventType resultEventType,
EventType[] typesPerStream,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorOutputConditionType outputConditionType,
OutputConditionPolledFactoryForge optionalOutputFirstConditionFactory,
MultiKeyClassRef multiKeyClassRef,
boolean unboundedProcessor) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
ResultSetProcessorRowPerGroupRollupForge.getMultiKeyClassRef() |
Constructor and Description |
---|
ResultSetProcessorRowPerGroupRollupForge(EventType resultEventType,
EventType[] typesPerStream,
GroupByRollupPerLevelForge perLevelForges,
ExprNode[] groupKeyNodeExpressions,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
AggregationGroupByRollupDescForge groupByRollupDesc,
boolean isJoin,
boolean isHistoricalOnly,
boolean iterateUnbounded,
ResultSetProcessorOutputConditionType outputConditionType,
OutputConditionPolledFactoryForge optionalOutputFirstConditionFactory,
EventType[] eventTypes,
MultiKeyClassRef multiKeyClassRef) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
SelectSubscriberDescriptor.getGroupDeliveryMultiKey() |
Constructor and Description |
---|
SelectSubscriberDescriptor(Class[] selectClauseTypes,
String[] selectClauseColumnNames,
boolean forClauseDelivery,
ExprNode[] groupDelivery,
MultiKeyClassRef groupDeliveryMultiKey) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
RowRecogDescForge.getPartitionByMultiKey() |
Constructor and Description |
---|
RowRecogDescForge(EventType parentEventType,
EventType rowEventType,
EventType compositeEventType,
EventType multimatchEventType,
int[] multimatchStreamNumToVariable,
int[] multimatchVariableToStreamNum,
ExprNode[] partitionBy,
MultiKeyClassRef partitionByMultiKey,
LinkedHashMap<String,Pair<Integer,Boolean>> variableStreams,
boolean hasInterval,
boolean iterateOnly,
boolean unbound,
boolean orTerminated,
boolean collectMultimatches,
boolean defineAsksMultimatches,
int numEventsEventsPerStreamDefine,
String[] multimatchVariablesArray,
RowRecogNFAStateForge[] startStates,
RowRecogNFAStateForge[] allStates,
boolean allMatches,
MatchRecognizeSkipEnum skip,
ExprNode[] columnEvaluators,
String[] columnNames,
TimePeriodComputeForge intervalCompute,
int[] previousRandomAccessIndexes,
AggregationServiceForgeDesc[] aggregationServices,
boolean isTargetHA) |
Constructor and Description |
---|
SubSelectStrategyFactoryLocalViewPreloadedForge(List<ViewFactoryForge> viewForges,
ViewResourceDelegateDesc viewResourceDelegateDesc,
Pair<EventTableFactoryFactoryForge,SubordTableLookupStrategyFactoryForge> lookupStrategy,
ExprNode filterExprNode,
boolean correlatedSubquery,
AggregationServiceForgeDesc aggregationServiceForgeDesc,
int subqueryNumber,
ExprNode[] groupKeys,
NamedWindowMetaData namedWindow,
ExprNode namedWindowFilterExpr,
QueryGraphForge namedWindowFilterQueryGraph,
MultiKeyClassRef groupByMultiKeyClasses,
boolean isTargetHA) |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
TableAccessAnalysisResult.getPrimaryKeyMultikeyClasses() |
Constructor and Description |
---|
TableAccessAnalysisResult(Map<String,TableMetadataColumn> tableColumns,
ObjectArrayEventType internalEventType,
DataInputOutputSerdeForge[] internalEventTypePropertySerdes,
ObjectArrayEventType publicEventType,
TableMetadataColumnPairPlainCol[] colsPlain,
TableMetadataColumnPairAggMethod[] colsAggMethod,
TableMetadataColumnPairAggAccess[] colsAccess,
AggregationRowStateForgeDesc aggDesc,
String[] primaryKeyColumns,
EventPropertyGetterSPI[] primaryKeyGetters,
EPTypeClass[] primaryKeyTypes,
int[] primaryKeyColNums,
MultiKeyClassRef primaryKeyMultikeyClasses,
List<StmtClassForgeableFactory> additionalForgeables) |
Modifier and Type | Field and Description |
---|---|
protected MultiKeyClassRef |
FirstUniqueByPropertyViewForge.multiKeyClassNames |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
FirstUniqueByPropertyViewForge.getMultiKeyClassNames() |
Modifier and Type | Field and Description |
---|---|
protected MultiKeyClassRef |
GroupByViewFactoryForge.multiKeyClassNames |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
GroupByViewFactoryForge.getMultiKeyClassNames() |
Modifier and Type | Field and Description |
---|---|
protected MultiKeyClassRef |
RankWindowViewForge.multiKeyClassNames |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
RankWindowViewForge.getMultiKeyClassNames() |
Modifier and Type | Field and Description |
---|---|
protected MultiKeyClassRef |
UniqueByPropertyViewForge.multiKeyClassNames |
Modifier and Type | Method and Description |
---|---|
MultiKeyClassRef |
UniqueByPropertyViewForge.getMultiKeyClassNames() |
Modifier and Type | Method and Description |
---|---|
static void |
ViewMultiKeyHelper.assign(ExprNode[] criteriaExpressions,
MultiKeyClassRef multiKeyClassNames,
CodegenMethod method,
CodegenExpressionRef factory,
SAIFFInitializeSymbol symbols,
CodegenClassScope classScope) |
Copyright © 2005–2021. All rights reserved.