The present invention captures streaming data and avoids continual
retrieval. The invention only looks at data once, has a time dependency
built into it, and data that is not consumed or relevant is discarded. The
invention includes an engine processor that processes data according to
stored information; stored rules that define engine operation, an input
events module for receiving events which provides a plurality of events.
Events are processed according to stored rules for generating a series of
valid results when input events match the rules. Rule states that have
been matched to an input event but have not produced a valid result are
stored in state storage. The state of a rule as stored enables the engine
to provide a valid result output upon a future reception of an input event
necessary to complete the rule. Transaction log module monitors the
operation of the engine for specified time period.
La présente invention capture des données coulantes et évite la récupération continuelle. L'invention regarde seulement des données une fois, a une dépendance de temps établie dans elle, et des données qui sont non consommées ou approprié sont jetées. L'invention inclut un processeur de moteur ces données de processus selon l'information stockée ; règles stockées qui définissent l'opération de moteur, un module d'événements d'entrée pour la réception des événements qui fournit une pluralité d'événements. Des événements sont traités selon des règles stockées pour produire d'une série de résultats valides quand les événements d'entrée assortissent les règles. Régnez les déclarer qui ont été assortis à un événement d'entrée mais le démuni a produit un résultat valide sont stockés dans le stockage d'état. L'état d'une règle en tant que stocké permet au moteur de fournir un résultat valide produit sur une future réception d'un événement d'entrée nécessaire pour accomplir la règle. Le module de notation de transaction surveille le fonctionnement du moteur pour la période de temps indiquée.