• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

Java StreamJoinAnalysisResult类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.espertech.esper.core.service.StreamJoinAnalysisResult类的典型用法代码示例。如果您正苦于以下问题：Java StreamJoinAnalysisResult类的具体用法？Java StreamJoinAnalysisResult怎么用？Java StreamJoinAnalysisResult使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



StreamJoinAnalysisResult类属于com.espertech.esper.core.service包，在下文中一共展示了StreamJoinAnalysisResult类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: StatementAgentInstanceFactorySelect

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
public StatementAgentInstanceFactorySelect(int numStreams, ViewableActivator[] eventStreamParentViewableActivators, StatementContext statementContext, StatementSpecCompiled statementSpec, EPServicesContext services, StreamTypeService typeService, ViewFactoryChain[] unmaterializedViewChain, ResultSetProcessorFactoryDesc resultSetProcessorFactoryDesc, StreamJoinAnalysisResult joinAnalysisResult, boolean recoveringResilient, JoinSetComposerPrototype joinSetComposerPrototype, SubSelectStrategyCollection subSelectStrategyCollection, ViewResourceDelegateVerified viewResourceDelegate, OutputProcessViewFactory outputProcessViewFactory) {
    super(statementSpec.getAnnotations());
    this.numStreams = numStreams;
    this.eventStreamParentViewableActivators = eventStreamParentViewableActivators;
    this.statementContext = statementContext;
    this.statementSpec = statementSpec;
    this.services = services;
    this.typeService = typeService;
    this.unmaterializedViewChain = unmaterializedViewChain;
    this.resultSetProcessorFactoryDesc = resultSetProcessorFactoryDesc;
    this.joinAnalysisResult = joinAnalysisResult;
    this.joinSetComposerPrototype = joinSetComposerPrototype;
    this.subSelectStrategyCollection = subSelectStrategyCollection;
    this.viewResourceDelegate = viewResourceDelegate;
    this.outputProcessViewFactory = outputProcessViewFactory;

    if (statementSpec.getFilterRootNode() != null) {
        filterRootNodeEvaluator = ExprNodeCompiler.allocateEvaluator(statementSpec.getFilterRootNode().getForge(), statementContext.getEngineImportService(), StatementAgentInstanceFactorySelect.class, false, statementContext.getStatementName());
    } else {
        filterRootNodeEvaluator = null;
    }
}
开发者ID:espertechinc，项目名称:esper，代码行数:23，代码来源:StatementAgentInstanceFactorySelect.java


示例2: testGetPlan

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
public void testGetPlan() throws Exception {
    OuterJoinDesc[] descList = new OuterJoinDesc[]{
            SupportOuterJoinDescFactory.makeDesc("intPrimitive", "s0", "intBoxed", "s1", OuterJoinType.LEFT)
    };

    QueryGraph queryGraph = new QueryGraph(2, null, false);
    EngineImportService engineImportService = SupportEngineImportServiceFactory.make();
    QueryPlan plan = QueryPlanBuilder.getPlan(typesPerStream, new OuterJoinDesc[0], queryGraph, null, new HistoricalViewableDesc(5), dependencyGraph, null, new StreamJoinAnalysisResult(2), true, null, null, engineImportService, false);
    assertPlan(plan);

    plan = QueryPlanBuilder.getPlan(typesPerStream, descList, queryGraph, null, new HistoricalViewableDesc(5), dependencyGraph, null, new StreamJoinAnalysisResult(2), true, null, null, engineImportService, false);
    assertPlan(plan);

    FilterExprAnalyzer.analyze(SupportExprNodeFactory.makeEqualsNode(), queryGraph, false);
    plan = QueryPlanBuilder.getPlan(typesPerStream, descList, queryGraph, null, new HistoricalViewableDesc(5), dependencyGraph, null, new StreamJoinAnalysisResult(2), true, null, null, engineImportService, false);
    assertPlan(plan);

    plan = QueryPlanBuilder.getPlan(typesPerStream, new OuterJoinDesc[0], queryGraph, null, new HistoricalViewableDesc(5), dependencyGraph, null, new StreamJoinAnalysisResult(2), true, null, null, engineImportService, false);
    assertPlan(plan);
}
开发者ID:espertechinc，项目名称:esper，代码行数:21，代码来源:TestQueryPlanBuilder.java


示例3: testGetPlan

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
public void testGetPlan() throws Exception
{
    List<OuterJoinDesc> descList = new LinkedList<OuterJoinDesc>();
    OuterJoinDesc joinDesc = SupportOuterJoinDescFactory.makeDesc("intPrimitive", "s0", "intBoxed", "s1", OuterJoinType.LEFT);
    descList.add(joinDesc);

    QueryGraph queryGraph = new QueryGraph(2);
    QueryPlan plan = QueryPlanBuilder.getPlan(typesPerStream, new LinkedList<OuterJoinDesc>(), queryGraph, null, new HistoricalViewableDesc(5), dependencyGraph, null, new StreamJoinAnalysisResult(2), true, null, null);
    assertPlan(plan);

    plan = QueryPlanBuilder.getPlan(typesPerStream, descList, queryGraph, null, new HistoricalViewableDesc(5), dependencyGraph, null, new StreamJoinAnalysisResult(2), true, null, null);
    assertPlan(plan);

    FilterExprAnalyzer.analyze(SupportExprNodeFactory.makeEqualsNode(), queryGraph, false);
    plan = QueryPlanBuilder.getPlan(typesPerStream, descList, queryGraph, null, new HistoricalViewableDesc(5), dependencyGraph, null, new StreamJoinAnalysisResult(2), true, null, null);
    assertPlan(plan);

    plan = QueryPlanBuilder.getPlan(typesPerStream, new LinkedList<OuterJoinDesc>(), queryGraph, null, new HistoricalViewableDesc(5), dependencyGraph, null, new StreamJoinAnalysisResult(2), true, null, null);
    assertPlan(plan);
}
开发者ID:mobile-event-processing，项目名称:Asper，代码行数:21，代码来源:TestQueryPlanBuilder.java


示例4: removeUnidirectionalAndTable

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
private static void removeUnidirectionalAndTable(QueryPlan queryPlan, StreamJoinAnalysisResult streamJoinAnalysisResult) {
    boolean allUnidirectional = streamJoinAnalysisResult.isUnidirectionalAll();
    for (int streamNum = 0; streamNum < queryPlan.getExecNodeSpecs().length; streamNum++) {
        if (allUnidirectional) {
            queryPlan.getExecNodeSpecs()[streamNum] = new QueryPlanNodeAllUnidirectionalOuter(streamNum);
        } else {
            boolean unidirectional = streamJoinAnalysisResult.isUnidirectional() && !streamJoinAnalysisResult.getUnidirectionalInd()[streamNum];
            boolean table = streamJoinAnalysisResult.getTablesPerStream()[streamNum] != null;
            if (unidirectional || table) {
                queryPlan.getExecNodeSpecs()[streamNum] = new QueryPlanNodeNoOp();
            }
        }
    }
}
开发者ID:espertechinc，项目名称:esper，代码行数:15，代码来源:QueryPlanBuilder.java


示例5: JoinSetComposerPrototypeImpl

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
public JoinSetComposerPrototypeImpl(String statementName,
                                    String statementId,
                                    List<OuterJoinDesc> outerJoinDescList,
                                    ExprNode optionalFilterNode,
                                    EventType[] streamTypes,
                                    String[] streamNames,
                                    StreamJoinAnalysisResult streamJoinAnalysisResult,
                                    Annotation[] annotations,
                                    HistoricalViewableDesc historicalViewableDesc,
                                    ExprEvaluatorContext exprEvaluatorContext,
                                    QueryPlanIndex[] indexSpecs,
                                    QueryPlan queryPlan,
                                    HistoricalStreamIndexList[] historicalStreamIndexLists,
                                    boolean joinRemoveStream,
                                    boolean isOuterJoins) {
    this.statementName = statementName;
    this.statementId = statementId;
    this.outerJoinDescList = outerJoinDescList;
    this.optionalFilterNode = optionalFilterNode;
    this.streamTypes = streamTypes;
    this.streamNames = streamNames;
    this.streamJoinAnalysisResult = streamJoinAnalysisResult;
    this.annotations = annotations;
    this.historicalViewableDesc = historicalViewableDesc;
    this.exprEvaluatorContext = exprEvaluatorContext;
    this.indexSpecs = indexSpecs;
    this.queryPlan = queryPlan;
    this.historicalStreamIndexLists = historicalStreamIndexLists;
    this.joinRemoveStream = joinRemoveStream;
    this.isOuterJoins = isOuterJoins;
}
开发者ID:mobile-event-processing，项目名称:Asper，代码行数:32，代码来源:JoinSetComposerPrototypeImpl.java


示例6: removeUnidirectional

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
private static void removeUnidirectional(QueryPlan queryPlan, StreamJoinAnalysisResult streamJoinAnalysisResult) {
    for (int streamNum = 0; streamNum < queryPlan.getExecNodeSpecs().length; streamNum++) {
        if (streamJoinAnalysisResult.isUnidirectional() && !streamJoinAnalysisResult.getUnidirectionalInd()[streamNum]) {
            queryPlan.getExecNodeSpecs()[streamNum] = new QueryPlanNodeNoOp();
        }
    }
}
开发者ID:mobile-event-processing，项目名称:Asper，代码行数:8，代码来源:QueryPlanBuilder.java


示例7: StatementAgentInstanceFactorySelect

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
public StatementAgentInstanceFactorySelect(int numStreams, ViewableActivator[] eventStreamParentViewableActivators, StatementContext statementContext, StatementSpecCompiled statementSpec, EPServicesContext services, StreamTypeService typeService, ViewFactoryChain[] unmaterializedViewChain, ResultSetProcessorFactoryDesc resultSetProcessorFactoryDesc, StreamJoinAnalysisResult joinAnalysisResult, boolean recoveringResilient, JoinSetComposerPrototype joinSetComposerPrototype, SubSelectStrategyCollection subSelectStrategyCollection, ViewResourceDelegateVerified viewResourceDelegate, OutputProcessViewFactory outputProcessViewFactory) {
    this.numStreams = numStreams;
    this.eventStreamParentViewableActivators = eventStreamParentViewableActivators;
    this.statementContext = statementContext;
    this.statementSpec = statementSpec;
    this.services = services;
    this.typeService = typeService;
    this.unmaterializedViewChain = unmaterializedViewChain;
    this.resultSetProcessorFactoryDesc = resultSetProcessorFactoryDesc;
    this.joinAnalysisResult = joinAnalysisResult;
    this.joinSetComposerPrototype = joinSetComposerPrototype;
    this.subSelectStrategyCollection = subSelectStrategyCollection;
    this.viewResourceDelegate = viewResourceDelegate;
    this.outputProcessViewFactory = outputProcessViewFactory;
}
开发者ID:mobile-event-processing，项目名称:Asper，代码行数:16，代码来源:StatementAgentInstanceFactorySelect.java


示例8: JoinSetComposerPrototypeImpl

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
public JoinSetComposerPrototypeImpl(String statementName,
                                    int statementId,
                                    OuterJoinDesc[] outerJoinDescList,
                                    ExprNode optionalFilterNode,
                                    EventType[] streamTypes,
                                    String[] streamNames,
                                    StreamJoinAnalysisResult streamJoinAnalysisResult,
                                    Annotation[] annotations,
                                    HistoricalViewableDesc historicalViewableDesc,
                                    ExprEvaluatorContext exprEvaluatorContext,
                                    QueryPlanIndex[] indexSpecs,
                                    QueryPlan queryPlan,
                                    HistoricalStreamIndexList[] historicalStreamIndexLists,
                                    boolean joinRemoveStream,
                                    boolean isOuterJoins,
                                    TableService tableService,
                                    EventTableIndexService eventTableIndexService,
                                    EngineImportService engineImportService,
                                    boolean isFireAndForget) {
    this.statementName = statementName;
    this.statementId = statementId;
    this.outerJoinDescList = outerJoinDescList;
    this.streamTypes = streamTypes;
    this.streamNames = streamNames;
    this.streamJoinAnalysisResult = streamJoinAnalysisResult;
    this.annotations = annotations;
    this.historicalViewableDesc = historicalViewableDesc;
    this.exprEvaluatorContext = exprEvaluatorContext;
    this.indexSpecs = indexSpecs;
    this.queryPlan = queryPlan;
    this.historicalStreamIndexLists = historicalStreamIndexLists;
    this.joinRemoveStream = joinRemoveStream;
    this.isOuterJoins = isOuterJoins;
    this.tableService = tableService;
    this.eventTableIndexService = eventTableIndexService;

    ExprNode filterExpression;
    if (isNonUnidirectionalNonSelf()) {
        filterExpression = getFilterExpressionInclOnClause(optionalFilterNode, outerJoinDescList);
    } else {
        filterExpression = optionalFilterNode;

    }
    postJoinFilterEvaluator = filterExpression == null ? null : ExprNodeCompiler.allocateEvaluator(filterExpression.getForge(), engineImportService, this.getClass(), isFireAndForget, statementName);
}
开发者ID:espertechinc，项目名称:esper，代码行数:46，代码来源:JoinSetComposerPrototypeImpl.java


示例9: getJoinAnalysisResult

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
public StreamJoinAnalysisResult getJoinAnalysisResult() {
    return joinAnalysisResult;
}
开发者ID:espertechinc，项目名称:esper，代码行数:4，代码来源:StatementAgentInstanceFactorySelect.java


示例10: handleJoin

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
private JoinPlanResult handleJoin(String[] streamNames,
                                  Viewable[] streamViews,
                                  ResultSetProcessor resultSetProcessor,
                                  AgentInstanceContext agentInstanceContext,
                                  List<StopCallback> stopCallbacks,
                                  StreamJoinAnalysisResult joinAnalysisResult,
                                  boolean isRecoveringResilient) {
    final JoinSetComposerDesc joinSetComposerDesc = joinSetComposerPrototype.create(streamViews, false, agentInstanceContext, isRecoveringResilient);

    stopCallbacks.add(new StopCallback() {
        public void stop() {
            joinSetComposerDesc.getJoinSetComposer().destroy();
        }
    });

    JoinSetFilter filter = new JoinSetFilter(joinSetComposerDesc.getPostJoinFilterEvaluator());
    OutputProcessViewBase indicatorView = outputProcessViewFactory.makeView(resultSetProcessor, agentInstanceContext);

    // Create strategy for join execution
    JoinExecutionStrategy execution = new JoinExecutionStrategyImpl(joinSetComposerDesc.getJoinSetComposer(), filter, indicatorView, agentInstanceContext);

    // The view needs a reference to the join execution to pull iterator values
    indicatorView.setJoinExecutionStrategy(execution);

    // Hook up dispatchable with buffer and execution strategy
    JoinExecStrategyDispatchable joinStatementDispatch = new JoinExecStrategyDispatchable(execution, statementSpec.getStreamSpecs().length);
    agentInstanceContext.getEpStatementAgentInstanceHandle().setOptionalDispatchable(joinStatementDispatch);

    JoinPreloadMethod preloadMethod;
    if (joinAnalysisResult.isUnidirectional()) {
        preloadMethod = new JoinPreloadMethodNull();
    } else {
        if (!joinSetComposerDesc.getJoinSetComposer().allowsInit()) {
            preloadMethod = new JoinPreloadMethodNull();
        } else {
            preloadMethod = new JoinPreloadMethodImpl(streamNames.length, joinSetComposerDesc.getJoinSetComposer());
        }
    }

    // Create buffer for each view. Point buffer to dispatchable for join.
    for (int i = 0; i < statementSpec.getStreamSpecs().length; i++) {
        BufferView buffer = new BufferView(i);
        streamViews[i].addView(buffer);
        buffer.setObserver(joinStatementDispatch);
        preloadMethod.setBuffer(buffer, i);
    }

    return new JoinPlanResult(indicatorView, preloadMethod, joinSetComposerDesc);
}
开发者ID:espertechinc，项目名称:esper，代码行数:50，代码来源:StatementAgentInstanceFactorySelect.java


示例11: handleJoin

import com.espertech.esper.core.service.StreamJoinAnalysisResult; //导入依赖的package包/类
private JoinPlanResult handleJoin(String[] streamNames,
                                                     Viewable[] streamViews,
                                                     ResultSetProcessor resultSetProcessor,
                                                     AgentInstanceContext agentInstanceContext,
                                                     List<StopCallback> stopCallbacks,
                                                     StreamJoinAnalysisResult joinAnalysisResult)
{
    final JoinSetComposerDesc joinSetComposerDesc = joinSetComposerPrototype.create(streamViews, false);

    stopCallbacks.add(new StopCallback(){
        public void stop()
        {
            joinSetComposerDesc.getJoinSetComposer().destroy();
        }
    });

    JoinSetFilter filter = new JoinSetFilter(joinSetComposerDesc.getPostJoinFilterEvaluator());
    OutputProcessViewBase indicatorView = outputProcessViewFactory.makeView(resultSetProcessor, agentInstanceContext);

    // Create strategy for join execution
    JoinExecutionStrategy execution = new JoinExecutionStrategyImpl(joinSetComposerDesc.getJoinSetComposer(), filter, indicatorView, agentInstanceContext);

    // The view needs a reference to the join execution to pull iterator values
    indicatorView.setJoinExecutionStrategy(execution);

    // Hook up dispatchable with buffer and execution strategy
    JoinExecStrategyDispatchable joinStatementDispatch = new JoinExecStrategyDispatchable(execution, statementSpec.getStreamSpecs().size());
    agentInstanceContext.getEpStatementAgentInstanceHandle().setOptionalDispatchable(joinStatementDispatch);

    JoinPreloadMethod preloadMethod;
    if (joinAnalysisResult.getUnidirectionalStreamNumber() >= 0)
    {
        preloadMethod = new JoinPreloadMethodNull();
    }
    else
    {
        preloadMethod = new JoinPreloadMethodImpl(streamNames.length, joinSetComposerDesc.getJoinSetComposer());
    }

    // Create buffer for each view. Point buffer to dispatchable for join.
    for (int i = 0; i < statementSpec.getStreamSpecs().size(); i++)
    {
        BufferView buffer = new BufferView(i);
        streamViews[i].addView(buffer);
        buffer.setObserver(joinStatementDispatch);
        preloadMethod.setBuffer(buffer, i);
    }

    return new JoinPlanResult(indicatorView, preloadMethod, joinSetComposerDesc);
}
开发者ID:mobile-event-processing，项目名称:Asper，代码行数:51，代码来源:StatementAgentInstanceFactorySelect.java



注：本文中的com.espertech.esper.core.service.StreamJoinAnalysisResult类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java MeaningSpan类代码示例发布时间：2022-05-16
下一篇：
Java ContentUsageImpl类代码示例发布时间：2022-05-16
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap