Modifier and Type | Method and Description |
---|---|
static MultiKeyPlan |
MultiKeyPlanner.planMultiKey(EPType[] types,
boolean lenientEquals,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver) |
static MultiKeyPlan |
MultiKeyPlanner.planMultiKey(ExprForge[] criteriaExpressions,
boolean lenientEquals,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver) |
static MultiKeyPlan |
MultiKeyPlanner.planMultiKey(ExprNode[] criteriaExpressions,
boolean lenientEquals,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver) |
static MultiKeyPlan |
MultiKeyPlanner.planMultiKeyDistinct(boolean isDistinct,
EventType eventType,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver) |
Modifier and Type | Method and Description |
---|---|
SerdeCompileTimeResolver |
StatementCompileTimeServices.getSerdeResolver() |
SerdeCompileTimeResolver |
ModuleCompileTimeServices.getSerdeResolver() |
Constructor and Description |
---|
ModuleCompileTimeServices(CompilerServices compilerServices,
Configuration configuration,
ClassProvidedCompileTimeRegistry classProvidedCompileTimeRegistry,
ClassProvidedCompileTimeResolver classProvidedCompileTimeResolver,
ContextCompileTimeRegistry contextCompileTimeRegistry,
ContextCompileTimeResolver contextCompileTimeResolver,
BeanEventTypeStemService beanEventTypeStemService,
BeanEventTypeFactoryPrivate beanEventTypeFactoryPrivate,
DatabaseConfigServiceCompileTime databaseConfigServiceCompileTime,
ClasspathImportServiceCompileTime classpathImportService,
ExprDeclaredCompileTimeRegistry exprDeclaredCompileTimeRegistry,
ExprDeclaredCompileTimeResolver exprDeclaredCompileTimeResolver,
EventTypeAvroHandler eventTypeAvroHandler,
EventTypeCompileTimeRegistry eventTypeCompileTimeRegistry,
EventTypeCompileTimeResolver eventTypeCompileTimeResolver,
EventTypeRepositoryImpl eventTypeRepositoryPreconfigured,
boolean fireAndForget,
IndexCompileTimeRegistry indexCompileTimeRegistry,
ModuleDependenciesCompileTime moduleDependencies,
ModuleAccessModifierService moduleVisibilityRules,
NamedWindowCompileTimeResolver namedWindowCompileTimeResolver,
NamedWindowCompileTimeRegistry namedWindowCompileTimeRegistry,
StateMgmtSettingsProvider stateMgmtSettingsProvider,
ParentClassLoader parentClassLoader,
PatternObjectResolutionService patternObjectResolutionService,
ScriptCompileTimeRegistry scriptCompileTimeRegistry,
ScriptCompileTimeResolver scriptCompileTimeResolver,
SerdeEventTypeCompileTimeRegistry serdeEventTypeRegistry,
SerdeCompileTimeResolver serdeResolver,
TableCompileTimeRegistry tableCompileTimeRegistry,
TableCompileTimeResolver tableCompileTimeResolver,
VariableCompileTimeRegistry variableCompileTimeRegistry,
VariableCompileTimeResolver variableCompileTimeResolver,
ViewResolutionService viewResolutionService,
XMLFragmentEventTypeFactory xmlFragmentEventTypeFactory) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
SerdeCompileTimeResolver |
ExprValidationContext.getSerdeResolver() |
Modifier and Type | Method and Description |
---|---|
JoinSetComposerPrototypeHistoricalDesc |
HistoricalStreamIndexListForge.getStrategy(int streamViewStreamNum,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver)
Get the strategies to use for polling from a given stream.
|
Modifier and Type | Method and Description |
---|---|
static JoinSetComposerPrototypeHistoricalDesc |
JoinSetComposerPrototypeForgeFactory.determineIndexing(QueryGraphForge queryGraph,
EventType polledViewType,
EventType streamViewType,
int polledViewStreamNum,
int streamViewStreamNum,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver)
Constructs indexing and lookup strategy for a given relationship that a historical stream may have with another
stream (historical or not) that looks up into results of a poll of a historical stream.
|
Modifier and Type | Method and Description |
---|---|
protected static QueryPlanForgeDesc |
NStreamQueryPlanBuilder.build(QueryGraphForge queryGraph,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexListForge[] historicalStreamIndexLists,
boolean hasForceNestedIter,
String[][][] indexedStreamsUniqueProps,
TableMetaData[] tablesPerStream,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver) |
static TableLookupPlanDesc |
NStreamQueryPlanBuilder.createLookupPlan(QueryGraphForge queryGraph,
int currentLookupStream,
int indexedStream,
boolean indexedStreamIsVDW,
QueryPlanIndexForge indexSpecs,
EventType[] typesPerStream,
TableMetaData indexedStreamTableMeta,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver)
Create the table lookup plan for a from-stream to look up in an indexed stream
using the columns supplied in the query graph and looking at the actual indexes available
and their index number.
|
protected static QueryPlanNodeForgeDesc |
NStreamQueryPlanBuilder.createStreamPlan(int lookupStream,
int[] bestChain,
QueryGraphForge queryGraph,
QueryPlanIndexForge[] indexSpecsPerStream,
EventType[] typesPerStream,
boolean[] isHistorical,
HistoricalStreamIndexListForge[] historicalStreamIndexLists,
TableMetaData[] tablesPerStream,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult,
StatementRawInfo raw,
SerdeCompileTimeResolver serdeResolver)
Walks the chain of lookups and constructs lookup strategy and plan specification based
on the index specifications.
|
Modifier and Type | Method and Description |
---|---|
SerdeCompileTimeResolver |
SelectProcessorArgs.getSerdeResolver() |
Modifier and Type | Method and Description |
---|---|
static SerdeEventPropertyDesc |
SerdeEventPropertyUtility.forgeForEventProperty(EventType eventTypeSerde,
String propertyName,
Object propertyType,
StatementRawInfo raw,
SerdeCompileTimeResolver resolver) |
static List<StmtClassForgeableFactory> |
SerdeEventTypeUtility.plan(EventType eventType,
StatementRawInfo raw,
SerdeEventTypeCompileTimeRegistry registry,
SerdeCompileTimeResolver resolver,
StateMgmtSettingsProvider stateMgmtSettingsProvider) |
Modifier and Type | Class and Description |
---|---|
class |
SerdeCompileTimeResolverImpl |
class |
SerdeCompileTimeResolverNonHA |
Modifier and Type | Method and Description |
---|---|
SerdeCompileTimeResolver |
ViewForgeEnv.getSerdeResolver() |
Copyright © 2005–2021. All rights reserved.