Modifier and Type | Method and Description |
---|---|
TableMetaData |
TableQueryStreamSpec.getTable() |
Constructor and Description |
---|
TableQueryStreamSpec(String optionalStreamName,
ViewSpec[] viewSpecs,
StreamSpecOptions streamSpecOptions,
TableMetaData table,
List<ExprNode> filterExpressions) |
Constructor and Description |
---|
ViewableActivatorTableForge(TableMetaData table,
ExprNode optionalFilterExpression) |
Modifier and Type | Method and Description |
---|---|
Map<String,TableMetaData> |
ModuleIncidentals.getTables() |
Constructor and Description |
---|
ModuleIncidentals(Map<String,NamedWindowMetaData> namedWindows,
Map<String,ContextMetaData> contexts,
Map<String,VariableMetaData> variables,
Map<String,ExpressionDeclItem> expressions,
Map<String,TableMetaData> tables) |
Constructor and Description |
---|
StatementAgentInstanceFactoryCreateIndexForge(EventType eventType,
String indexName,
String indexModuleName,
QueryPlanIndexItemForge explicitIndexDesc,
IndexMultiKey imk,
NamedWindowMetaData namedWindow,
TableMetaData table) |
Modifier and Type | Method and Description |
---|---|
TableMetaData |
OnSplitItemForge.getInsertIntoTable() |
Constructor and Description |
---|
OnSplitItemForge(ExprNode whereClause,
boolean isNamedWindowInsert,
TableMetaData insertIntoTable,
ResultSetProcessorDesc resultSetProcessorDesc,
PropertyEvaluatorForge propertyEvaluator) |
Modifier and Type | Field and Description |
---|---|
protected TableMetaData |
StatementAgentInstanceFactoryOnTriggerInfraBaseForge.table |
Modifier and Type | Method and Description |
---|---|
static OnTriggerPlan |
OnTriggerWindowUtil.handleContextFactoryOnTrigger(String className,
CodegenPackageScope packageScope,
String classPostfix,
NamedWindowMetaData namedWindow,
TableMetaData table,
OnTriggerWindowPlan planDesc,
StatementBaseInfo base,
StatementCompileTimeServices services) |
Modifier and Type | Method and Description |
---|---|
TableMetaData[] |
StreamJoinAnalysisResultCompileTime.getTablesPerStream() |
Modifier and Type | Method and Description |
---|---|
void |
StreamJoinAnalysisResultCompileTime.setTablesForStream(int streamNum,
TableMetaData metadata) |
Modifier and Type | Method and Description |
---|---|
PathRegistry<String,TableMetaData> |
EPStatementInitServices.getTablePathRegistry() |
Constructor and Description |
---|
AggregationAccessorMinMaxByTable(boolean max,
TableMetaData table) |
AggregationAccessorSortedTable(boolean max,
Class componentType,
TableMetaData table) |
AggregationTAAReaderSortedMinMaxByForge(Class resultType,
boolean max,
TableMetaData table) |
Constructor and Description |
---|
AggregationServiceFactoryForgeTable(TableMetaData metadata,
TableColumnMethodPairForge[] methodPairs,
int[] accessColumnsZeroOffset,
AggregationAgentForge[] accessAgents,
AggregationGroupByRollupDesc groupByRollupDesc) |
Constructor and Description |
---|
ExprDotForgeUnpackBeanTable(EventType lambdaType,
TableMetaData tableMetadata) |
ExprDotForgeUnpackCollEventBeanTable(EventType type,
TableMetaData table) |
Modifier and Type | Method and Description |
---|---|
static ExprForge |
ExprNodeUtilityMake.makeUnderlyingForge(int streamNum,
Class resultType,
TableMetaData tableMetadata) |
Modifier and Type | Field and Description |
---|---|
protected TableMetaData |
ExprEvalEnumerationAtBeanCollTable.table |
Constructor and Description |
---|
ExprEvalEnumerationAtBeanCollTable(ExprEnumerationForge enumerationForge,
TableMetaData table) |
ExprEvalStreamInsertTable(int streamNum,
TableMetaData tableMetadata,
Class returnType) |
ExprEvalStreamNumEventTable(int streamNum,
TableMetaData table) |
ExprEvalStreamTable(int streamNum,
Class returnType,
TableMetaData tableMetadata) |
ExprEvalUnderlyingEvaluatorTable(int streamNum,
Class resultType,
TableMetaData tableMetadata) |
Constructor and Description |
---|
SubselectForgeStrategyRowFilteredUnselectedTable(ExprSubselectRowNode subselect,
TableMetaData table) |
SubselectForgeStrategyRowUnfilteredUnselectedTable(ExprSubselectRowNode subselect,
TableMetaData table) |
Modifier and Type | Field and Description |
---|---|
protected TableMetaData |
ExprTableAccessNode.tableMeta |
Modifier and Type | Method and Description |
---|---|
protected void |
ExprTableAccessNode.validateGroupKeys(TableMetaData metadata,
ExprValidationContext validationContext) |
protected TableMetadataColumn |
ExprTableAccessNode.validateSubpropertyGetCol(TableMetaData tableMetadata,
String subpropName) |
Constructor and Description |
---|
ExprTableIdentNode(TableMetaData tableMetadata,
String streamOrPropertyName,
String unresolvedPropertyName,
Class returnType,
int streamNum,
int columnNum) |
ExprTableIdentNodeSubpropAccessor(int streamNum,
String optionalStreamName,
TableMetaData table,
TableMetadataColumnAggregation tableAccessColumn,
ExprNode aggregateAccessMultiValueNode) |
Modifier and Type | Method and Description |
---|---|
TableMetaData |
FireAndForgetProcessorTableForge.getTable() |
Constructor and Description |
---|
FireAndForgetProcessorTableForge(TableMetaData table) |
Constructor and Description |
---|
IndexCollectorCompileTime(Map<String,NamedWindowMetaData> moduleNamedWindows,
Map<String,TableMetaData> moduleTables,
PathRegistry<String,NamedWindowMetaData> pathNamedWindows,
PathRegistry<String,TableMetaData> pathTables) |
IndexCollectorCompileTime(Map<String,NamedWindowMetaData> moduleNamedWindows,
Map<String,TableMetaData> moduleTables,
PathRegistry<String,NamedWindowMetaData> pathNamedWindows,
PathRegistry<String,TableMetaData> pathTables) |
Modifier and Type | Method and Description |
---|---|
protected static QueryPlanForge |
NStreamQueryPlanBuilder.build(QueryGraphForge queryGraph,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexListForge[] historicalStreamIndexLists,
boolean hasForceNestedIter,
String[][][] indexedStreamsUniqueProps,
TableMetaData[] tablesPerStream,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult) |
protected static QueryPlanForge |
NStreamOuterQueryPlanBuilder.build(QueryGraphForge queryGraph,
OuterJoinDesc[] outerJoinDescList,
String[] streamNames,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexListForge[] historicalStreamIndexLists,
String[][][] indexedStreamsUniqueProps,
TableMetaData[] tablesPerStream,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult,
StatementRawInfo statementRawInfo,
StatementCompileTimeServices services) |
static TableLookupPlanForge |
NStreamQueryPlanBuilder.createLookupPlan(QueryGraphForge queryGraph,
int currentLookupStream,
int indexedStream,
boolean indexedStreamIsVDW,
QueryPlanIndexForge indexSpecs,
EventType[] typesPerStream,
TableMetaData indexedStreamTableMeta)
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 QueryPlanNodeForge |
NStreamQueryPlanBuilder.createStreamPlan(int lookupStream,
int[] bestChain,
QueryGraphForge queryGraph,
QueryPlanIndexForge[] indexSpecsPerStream,
EventType[] typesPerStream,
boolean[] isHistorical,
HistoricalStreamIndexListForge[] historicalStreamIndexLists,
TableMetaData[] tablesPerStream,
StreamJoinAnalysisResultCompileTime streamJoinAnalysisResult)
Walks the chain of lookups and constructs lookup strategy and plan specification based
on the index specifications.
|
Modifier and Type | Method and Description |
---|---|
TableMetaData |
InfraOnMergeActionInsForge.getInsertIntoTable() |
Constructor and Description |
---|
InfraOnMergeActionInsForge(ExprNode optionalFilter,
SelectExprProcessorForge insertHelper,
TableMetaData insertIntoTable,
boolean audit,
boolean route) |
InfraOnMergeActionUpdForge(ExprNode optionalFilter,
EventBeanUpdateHelperForge updateHelper,
TableMetaData table) |
InfraOnMergeHelperForge(OnTriggerMergeDesc onTriggerDesc,
EventType triggeringEventType,
String triggeringStreamName,
String infraName,
EventTypeSPI infraEventType,
StatementRawInfo statementRawInfo,
StatementCompileTimeServices services,
TableMetaData table) |
Constructor and Description |
---|
OutputStrategyPostProcessForge(boolean isRouted,
SelectClauseStreamSelectorEnum insertIntoStreamSelector,
SelectClauseStreamSelectorEnum selectStreamSelector,
boolean routeToFront,
TableMetaData table,
boolean audit) |
Modifier and Type | Method and Description |
---|---|
TableMetaData |
SelectClauseStreamCompiledSpec.getTableMetadata() |
Modifier and Type | Method and Description |
---|---|
void |
SelectClauseStreamCompiledSpec.setTableMetadata(TableMetaData tableMetadata) |
Constructor and Description |
---|
BindProcessorStreamTable(int streamNum,
Class returnType,
TableMetaData tableMetadata) |
Constructor and Description |
---|
SelectEvalStreamWUnderlying(SelectExprForgeContext selectExprForgeContext,
EventType resultEventType,
List<SelectClauseStreamCompiledSpec> namedStreams,
boolean usingWildcard,
List<SelectExprStreamDesc> unnamedStreams,
boolean singleStreamWrapper,
boolean underlyingIsFragmentEvent,
int underlyingStreamNumber,
EventPropertyGetterSPI underlyingPropertyEventGetter,
ExprForge underlyingExprForge,
TableMetaData tableMetadata,
EventType[] eventTypes) |
SelectEvalWildcardTable(TableMetaData table) |
Constructor and Description |
---|
SubSelectStrategyFactoryIndexShareForge(int subqueryNumber,
SubSelectActivationPlan subselectActivation,
EventType[] outerEventTypesSelect,
NamedWindowMetaData namedWindow,
TableMetaData table,
boolean fullTableScan,
IndexHint indexHint,
SubordPropPlan joinedPropPlan,
ExprForge filterExprEval,
ExprNode[] groupKeys,
AggregationServiceForgeDesc aggregationServiceForgeDesc,
StatementBaseInfo statement,
StatementCompileTimeServices services) |
Modifier and Type | Method and Description |
---|---|
TableMetaData |
TableMetaData.copy() |
TableMetaData |
TableCompileTimeRegistry.getTable(String tableName) |
TableMetaData |
TableCompileTimeResolverImpl.resolve(String tableName) |
TableMetaData |
TableCompileTimeResolverEmpty.resolve(String tableName) |
TableMetaData |
TableCompileTimeResolver.resolve(String tableName) |
TableMetaData |
TableCompileTimeResolverImpl.resolveTableFromEventType(EventType containedType) |
TableMetaData |
TableCompileTimeResolverEmpty.resolveTableFromEventType(EventType containedType) |
TableMetaData |
TableCompileTimeResolver.resolveTableFromEventType(EventType containedType) |
Modifier and Type | Method and Description |
---|---|
Map<String,TableMetaData> |
TableCompileTimeRegistry.getTables() |
Modifier and Type | Method and Description |
---|---|
void |
TableCompileTimeRegistry.newTable(TableMetaData metaData) |
Constructor and Description |
---|
TableCompileTimeRegistry(Map<String,TableMetaData> tables) |
TableCompileTimeResolverImpl(String moduleName,
Set<String> moduleUses,
TableCompileTimeRegistry compileTimeRegistry,
PathRegistry<String,TableMetaData> pathTables,
ModuleDependenciesCompileTime moduleDependencies) |
Modifier and Type | Field and Description |
---|---|
protected TableMetaData |
TableBase.metaData |
Modifier and Type | Method and Description |
---|---|
TableMetaData |
TableBase.getMetaData() |
TableMetaData |
Table.getMetaData() |
Modifier and Type | Method and Description |
---|---|
void |
TableDeployment.add(String tableName,
TableMetaData metadata,
EPStatementInitServices services) |
void |
TableManagementServiceBase.addTable(String tableName,
TableMetaData tableMetaData,
EPStatementInitServices services) |
void |
TableManagementService.addTable(String tableName,
TableMetaData tableMetaData,
EPStatementInitServices services) |
Table |
TableManagementServiceImpl.allocateTable(TableMetaData metadata) |
Table |
TableManagementService.allocateTable(TableMetaData metadata) |
static CodegenExpression |
TableDeployTimeResolver.makeResolveTable(TableMetaData table,
CodegenExpression initSvc) |
static CodegenExpressionField |
TableDeployTimeResolver.makeTableEventToPublicField(TableMetaData table,
CodegenClassScope classScope,
Class generator) |
void |
TableCollectorImpl.registerTable(String tableName,
TableMetaData table) |
void |
TableCollector.registerTable(String tableName,
TableMetaData table) |
Constructor and Description |
---|
TableBase(TableMetaData metaData) |
TableImpl(TableMetaData metaData) |
Constructor and Description |
---|
TableCollectorImpl(Map<String,TableMetaData> moduleTables) |
Constructor and Description |
---|
ExprTableEvalStrategyFactoryForge(TableMetaData tableMeta,
ExprForge[] optionalGroupKeys) |
Modifier and Type | Method and Description |
---|---|
static TableUpdateStrategy |
TableUpdateStrategyFactory.validateGetTableUpdateStrategy(TableMetaData tableMetadata,
EventBeanUpdateHelperNoCopy updateHelper,
boolean isOnMerge) |
static void |
TableUpdateStrategyFactory.validateTableUpdateOnMerge(TableMetaData tableMetadata,
String[] updatedProperties) |
Modifier and Type | Method and Description |
---|---|
PathRegistry<String,TableMetaData> |
EPCompilerPathableImpl.getTablePathRegistry() |
Constructor and Description |
---|
EPCompilerPathableImpl(PathRegistry<String,VariableMetaData> variablePathRegistry,
PathRegistry<String,EventType> eventTypePathRegistry,
PathRegistry<String,ExpressionDeclItem> exprDeclaredPathRegistry,
PathRegistry<String,NamedWindowMetaData> namedWindowPathRegistry,
PathRegistry<String,TableMetaData> tablePathRegistry,
PathRegistry<String,ContextMetaData> contextPathRegistry,
PathRegistry<NameAndParamNum,ExpressionScriptProvided> scriptPathRegistry,
EventTypeRepositoryImpl eventTypePreconfigured,
VariableRepositoryPreconfigured variablePreconfigured) |
Copyright © 2005–2018. All rights reserved.