Examples of EventBean

club.beans.EventBean
@author sior
com.espertech.esper.client.EventBean
Interface for event representation. All events have an {@link EventType}. Events also usually have one or more event properties. This interface allows the querying of event type, event property values and the underlying event object.
org.fenixedu.academic.domain.util.icalendar.EventBean
org.jboss.weld.bean.builtin.EventBean
org.keycloak.email.freemarker.beans.EventBean
@author Stian Thorgersen
org.opencustomer.webapp.module.calendar.util.EventBean

Examples of com.espertech.esper.client.EventBean

    }


    public Object evaluate(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
    {
        RegexPartitionStateRandomAccess access = getter.getAccessor();
        EventBean substituteEvent = access.getPreviousEvent(assignedIndex);


        if (substituteEvent == null)
        {
            return null;
        }


        // Substitute original event with prior event, evaluate inner expression
        EventBean originalEvent = eventsPerStream[streamNumber];
        eventsPerStream[streamNumber] = substituteEvent;
        Object evalResult = evaluator.evaluate(eventsPerStream, isNewData, exprEvaluatorContext);
        eventsPerStream[streamNumber] = originalEvent;


        return evalResult;

View Full Code Here

Examples of com.espertech.esper.client.EventBean

        final EventStream sourceEventStream = new ZeroDepthStream(eventType);
        final StatementContext statementContext = patternContext.getStatementContext();
        final PatternMatchCallback callback = new PatternMatchCallback() {
            public void matchFound(Map<String, Object> matchEvent)
            {
                EventBean compositeEvent = statementContext.getEventAdapterService().adapterForTypedMap(matchEvent, eventType);
                sourceEventStream.insert(compositeEvent);
            }
        };


        EvalRootState rootState = rootNode.start(callback, patternContext, isRecoveringResilient);

View Full Code Here

Examples of com.espertech.esper.client.EventBean


    public EventBean update(EventBean matchingEvent, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
    {
        if (InstrumentationHelper.ENABLED) { InstrumentationHelper.get().qNamedWindowUpdate(matchingEvent, eventsPerStream, updateItems.length);}


        EventBean copy = copyMethod.copy(matchingEvent);
        eventsPerStream[0] = copy;
        eventsPerStream[2] = matchingEvent; // initial value


        for (int i = 0; i < updateItems.length; i++) {
            NamedWindowUpdateItem updateItem = updateItems[i];

View Full Code Here

Examples of com.espertech.esper.client.EventBean


        if (oldData != null)
        {
            boolean isOutOfSequenceRemove = false;


            EventBean first = null;
            if (!windowMatchedEventset.isEmpty())
            {
                first = windowMatchedEventset.iterator().next();
            }

View Full Code Here

Examples of com.espertech.esper.client.EventBean

        List<RegexNFAStateEntry> endStates = new ArrayList<RegexNFAStateEntry>();
        List<RegexNFAStateEntry> nextStates = new ArrayList<RegexNFAStateEntry>();
        List<RegexNFAStateEntry> currentStates;
        int eventSequenceNumber = 0;


        EventBean theEvent;
        for (;events.hasNext();)
        {
            theEvent = events.next();
            eventSequenceNumber++;


            RegexPartitionState partitionState = regexPartitionStateRepo.getState(theEvent, false);
            currentStates = partitionState.getCurrentStates();


            // add start states for each new event
            for (RegexNFAState startState : startStates)
            {
                long time = 0;
                if (matchRecognizeSpec.getInterval() != null)
                {
                    time = agentInstanceContext.getStatementContext().getSchedulingService().getTime();
                }
                currentStates.add(new RegexNFAStateEntry(eventSequenceNumber, time, startState, new EventBean[numEventsEventsPerStreamDefine], new int[allStates.length], null, partitionState.getOptionalKeys()));
            }


            if (partitionState.getRandomAccess() != null)
            {
                partitionState.getRandomAccess().existingEventPrepare(theEvent);
            }


            if ((ExecutionPathDebugLog.isDebugEnabled) && (log.isDebugEnabled()) || (IS_DEBUG))
            {
                log.info("Evaluating event " + theEvent.getUnderlying() + "\n" +
                    "current : " + printStates(currentStates));
            }


            step(currentStates, theEvent, nextStates, endStates, false, eventSequenceNumber, partitionState.getOptionalKeys());


            if ((ExecutionPathDebugLog.isDebugEnabled) && (log.isDebugEnabled()) || (IS_DEBUG))
            {
                log.info("Evaluating event " + theEvent.getUnderlying() + "\n" +
                    "next : " + printStates(nextStates) + "\n" +
                    "end : " + printStates(endStates));
            }


            partitionState.setCurrentStates(nextStates);

View Full Code Here

Examples of com.espertech.esper.client.EventBean

                        aggregationService.applyEnter(eventsPerStream, streamNum, agentInstanceContext);
                    }
                }
            }
        }
        EventBean rowRaw = agentInstanceContext.getStatementContext().getEventAdapterService().adapterForTypedMap(rowDataRaw, compositeEventType);


        Map<String, Object> row = new HashMap<String, Object>();
        int columnNum = 0;
        for (ExprEvaluator expression : columnEvaluators)
        {

View Full Code Here

Examples of com.espertech.esper.client.EventBean

                        }
                    }
                }
            }
            else {
                EventBean termStreamEvent = terminationState.getEventsPerStream()[stream];
                EventBean endStreamEvent = endState.getEventsPerStream()[stream];
                if (endStreamEvent != null && endStreamEvent != termStreamEvent) {
                    return false;
                }
            }
        }

View Full Code Here

Examples of com.espertech.esper.client.EventBean


    public EventBean next()
    {
        if (nextResult != null)
        {
            EventBean result = nextResult;
            nextResult = null;
            return result;
        }
        findNext();
        if (nextResult != null)
        {
            EventBean result = nextResult;
            nextResult = null;
            return result;
        }
        throw new NoSuchElementException();
    }

View Full Code Here

Examples of com.espertech.esper.client.EventBean


    private void findNext()
    {
        while (sourceIterator.hasNext())
        {
            EventBean candidate = sourceIterator.next();
            eventsPerStream[0] = candidate;


            Object groupKey = resultSetProcessor.generateGroupKey(eventsPerStream, true);
            aggregationService.setCurrentAccess(groupKey, exprEvaluatorContext.getAgentInstanceId());

View Full Code Here

Examples of com.espertech.esper.client.EventBean


    public Object evaluate(Object target, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) {
        if (target == null) {
            return null;
        }
        EventBean theEvent = (EventBean) target;
        return theEvent.getUnderlying();
    }

View Full Code Here

0 1 2 3 4 5

TOP

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.