Package com.espertech.esper.view.window

Examples of com.espertech.esper.view.window.RandomAccessByIndexGetter

86
87
88
89
90
91
92
        eventType = parentEventType;
    }

    public Object makePreviousGetter() {
        return new RandomAccessByIndexGetter();
    }
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
    public static IStreamRandomAccess getOptPreviousExprRandomAccess(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) {
        IStreamRandomAccess randomAccess = null;
        if (agentInstanceViewFactoryContext.getPreviousNodeGetter() != null)
        {
            RandomAccessByIndexGetter getter = (RandomAccessByIndexGetter) agentInstanceViewFactoryContext.getPreviousNodeGetter();
            randomAccess = new IStreamRandomAccess(getter);
            getter.updated(randomAccess);
        }
        return randomAccess;
    }
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
105
    public static IStreamSortRankRandomAccess getOptPreviousExprSortedRankedAccess(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) {
        IStreamSortRankRandomAccess rankedRandomAccess = null;

        if (agentInstanceViewFactoryContext.getPreviousNodeGetter() != null)
        {
            RandomAccessByIndexGetter getter = (RandomAccessByIndexGetter) agentInstanceViewFactoryContext.getPreviousNodeGetter();
            rankedRandomAccess = new IStreamSortRankRandomAccess(getter);
            getter.updated(rankedRandomAccess);
        }

        return rankedRandomAccess;
    }
View Full Code Here
142
143
144
145
146
147
148
        ExprEvaluator[] sortEvals = ExprNodeUtility.getEvaluators(sortCriteriaExpressions);
        return new RankWindowView(this, uniqueCriteriaExpressions, uniqueEvals, sortCriteriaExpressions, sortEvals, isDescendingValues, sortWindowSize, rankedRandomAccess, useCollatorSort, agentInstanceViewFactoryContext);
    }

    public Object makePreviousGetter() {
        return new RandomAccessByIndexGetter();
    }
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
        if (previousRequests.isEmpty()) {
            return;
        }
       
        RandomAccessByIndexGetter randomAccessGetter = null;
        RelativeAccessByEventNIndexMap relativeAccessGetter = null;
        if (previousNodeGetter instanceof RandomAccessByIndexGetter) {
            randomAccessGetter = (RandomAccessByIndexGetter) previousNodeGetter;
        }
        else if (previousNodeGetter instanceof RelativeAccessByEventNIndexMap) {
View Full Code Here
103
104
105
106
107
108
109
        ExprEvaluator[] childEvals = ExprNodeUtility.getEvaluators(sortCriteriaExpressions);
        return new SortWindowView(this, sortCriteriaExpressions, childEvals, isDescendingValues, sortWindowSize, sortedRandomAccess, useCollatorSort, agentInstanceViewFactoryContext);
    }

    public Object makePreviousGetter() {
        return new RandomAccessByIndexGetter();
    }
View Full Code Here
86
87
88
89
90
91
92
        eventType = parentEventType;
    }

    public Object makePreviousGetter() {
        return new RandomAccessByIndexGetter();
    }
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
        if (previousRequests.isEmpty()) {
            return;
        }
       
        RandomAccessByIndexGetter randomAccessGetter = null;
        RelativeAccessByEventNIndexMap relativeAccessGetter = null;
        if (previousNodeGetter instanceof RandomAccessByIndexGetter) {
            randomAccessGetter = (RandomAccessByIndexGetter) previousNodeGetter;
        }
        else if (previousNodeGetter instanceof RelativeAccessByEventNIndexMap) {
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
{
    public static IStreamRandomAccess getOptPreviousExprRandomAccess(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) {
        IStreamRandomAccess randomAccess = null;
        if (agentInstanceViewFactoryContext.getPreviousNodeGetter() != null)
        {
            RandomAccessByIndexGetter getter = (RandomAccessByIndexGetter) agentInstanceViewFactoryContext.getPreviousNodeGetter();
            randomAccess = new IStreamRandomAccess(getter);
            getter.updated(randomAccess);
        }
        return randomAccess;
    }
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
68
    public static IStreamSortedRandomAccess getOptPreviousExprSortedAccess(AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) {
        IStreamSortedRandomAccess sortedRandomAccess = null;

        if (agentInstanceViewFactoryContext.getPreviousNodeGetter() != null)
        {
            RandomAccessByIndexGetter getter = (RandomAccessByIndexGetter) agentInstanceViewFactoryContext.getPreviousNodeGetter();
            sortedRandomAccess = new IStreamSortedRandomAccess(getter);
            getter.updated(sortedRandomAccess);
        }

        return sortedRandomAccess;
    }
View Full Code Here
TOP

Related Classes of com.espertech.esper.view.window.RandomAccessByIndexGetter

  • com.espertech.esper.core.start.EPStatementStartMethodHelperPrevious
  • com.espertech.esper.epl.expression.ExprPreviousNode
  • com.espertech.esper.view.ext.RankWindowViewFactory
  • com.espertech.esper.view.ext.SortWindowViewFactory
  • com.espertech.esper.view.ext.TimeOrderViewFactory
  • com.espertech.esper.view.ViewServiceHelper
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.