Package com.espertech.esper.event.map

Examples of com.espertech.esper.event.map.MapEventBean


        return EventAdapterServiceHelper.adapterForType(theEvent, eventType, this);
    }

    public final EventBean adapterForTypedMap(Map<String, Object> properties, EventType eventType)
    {
        return new MapEventBean(properties, eventType);
    }
View Full Code Here


        }
    }

    public View makeView(final AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
    {
        MapEventBean builtinMapBean = new MapEventBean(new HashMap<String, Object>(), builtinMapType);
        IStreamRelativeAccess relativeAccessByEvent = ViewServiceHelper.getOptPreviousExprRelativeAccess(agentInstanceViewFactoryContext);
        return new ExpressionBatchView(this, relativeAccessByEvent, expiryExpression.getExprEvaluator(), aggregationServiceFactoryDesc, builtinMapBean, variableNames, agentInstanceViewFactoryContext);
    }
View Full Code Here

        expiryExpression = expressionParameters.get(0);
    }

    public View makeView(final AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
    {
        MapEventBean builtinMapBean = new MapEventBean(new HashMap<String, Object>(), builtinMapType);
        IStreamRandomAccess randomAccess = ViewServiceHelper.getOptPreviousExprRandomAccess(agentInstanceViewFactoryContext);
        return new ExpressionWindowView(this, randomAccess, expiryExpression.getExprEvaluator(), aggregationServiceFactoryDesc, builtinMapBean, variableNames, agentInstanceViewFactoryContext);
    }
View Full Code Here

        return EventAdapterServiceHelper.adapterForType(event, eventType, this);
    }

    public final EventBean adaptorForTypedMap(Map<String, Object> properties, EventType eventType)
    {
        return new MapEventBean(properties, eventType);
    }
View Full Code Here

    protected final MapEventBean evalEvent;

    public EnumEvalBaseScalar(ExprEvaluator innerExpression, int streamCountIncoming, MapEventType type, String propertyName) {
        super(innerExpression, streamCountIncoming);
        this.evalPropertyName = propertyName;
        this.evalEvent = new MapEventBean(new HashMap<String, Object>(), type);
    }
View Full Code Here

    protected EventBean[] eventsLambda;

    public EnumEvalBaseIndex(ExprEvaluator innerExpression, int streamNumLambda, MapEventType indexEventType, String indexPropertyName) {
        this.innerExpression = innerExpression;
        this.streamNumLambda = streamNumLambda;
        this.indexEvent = new MapEventBean(new HashMap<String, Object>(), indexEventType);
        this.indexPropertyName = indexPropertyName;
        this.eventsLambda = new EventBean[streamNumLambda + 2];
    }
View Full Code Here

                                 ExprEvaluator innerExpression, int streamNumLambda,
                                 MapEventType resultEventType, String resultPropertyName) {
        this.initialization = initialization;
        this.innerExpression = innerExpression;
        this.streamNumLambda = streamNumLambda;
        this.resultEvent = new MapEventBean(new HashMap<String, Object>(), resultEventType);
        this.resultPropertyName = resultPropertyName;
        this.eventsLambda = new EventBean[streamNumLambda + 2];
    }
View Full Code Here

    public EnumEvalBaseScalarIndex(ExprEvaluator innerExpression, int streamNumLambda, MapEventType evalEventType, String evalPropertyName, MapEventType indexEventType, String indexPropertyName) {
        this.innerExpression = innerExpression;
        this.streamNumLambda = streamNumLambda;
        this.evalPropertyName = evalPropertyName;
        this.evalEvent = new MapEventBean(new HashMap<String, Object>(), evalEventType);
        this.indexPropertyName = indexPropertyName;
        this.indexEvent = new MapEventBean(new HashMap<String, Object>(), indexEventType);
        this.eventsLambda = new EventBean[streamNumLambda + 2];
    }
View Full Code Here

    private MapEventBean evalEvent;
    private String evalPropertyName;

    public EnumEvalAggregateScalar(ExprEvaluator initialization, ExprEvaluator innerExpression, int streamNumLambda, MapEventType resultEventType, String resultPropertyName, MapEventType evalEventType, String evalPropertyName) {
        super(initialization, innerExpression, streamNumLambda, resultEventType, resultPropertyName);
        this.evalEvent = new MapEventBean(new HashMap<String, Object>(), evalEventType);
        this.evalPropertyName = evalPropertyName;
    }
View Full Code Here

    private EventBean[] eventsLambda;

    public EnumEvalTakeWhileIndexEvents(ExprEvaluator innerExpression, int streamNumLambda, MapEventType indexEventType, String indexPropertyName) {
        this.innerExpression = innerExpression;
        this.streamNumLambda = streamNumLambda;
        this.indexEvent = new MapEventBean(new HashMap<String, Object>(), indexEventType);
        this.indexPropertyName = indexPropertyName;
        this.eventsLambda = new EventBean[streamNumLambda + 2];
    }
View Full Code Here

TOP

Related Classes of com.espertech.esper.event.map.MapEventBean

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.