Az Event Stream Processing (ESP ) olyan technológiák összessége, amelyeket eseményfeldolgozási információs rendszerek felépítésére terveztek. Az ESP technológia magában foglalja az eseményvizualizációt, az eseménytárolást, az eseményvezérelt köztes szoftvert és az eseményfeldolgozó programozási nyelveket. Az ESP fő feladata az eseményfolyamok (adatok) feldolgozása annak érdekében, hogy értelmes mintákat találjon bennük, olyan módszerekkel, mint az események közötti kapcsolatok keresése, az események korrelációja, az eseményhierarchiák és egyéb szempontok, mint az ok-okozati összefüggés, az összetett elemzés események és idősorok.
Az ESP technológiát különféle alkalmazásokban használják, például a csalások korai felismerésében a pénzügyi szolgáltatási ágazatban; a tőzsdei kereskedési padlókon végzett tevékenységek operatív elemzéséhez; a berendezések teljesítményének értékelése érzékelőktől és érzékelőktől származó heterogén információk alapján, például az olaj- és gáziparban; a távközlésben ügyféllemorzsolódás és marketingkampányok operatív elemzéséhez stb.
Illusztrációként a következő kódrészletek a mintaérzékelést mutatják be egy eseményfolyamon belül. Az első példa egy eseményfolyam feldolgozása folyamatos SQL-lekérdezéssel (olyan lekérdezés, amely időbélyegek alapján folyamatosan feldolgozza a bejövő adatokat). Ebben a kódrészletben a JOIN művelet két adatfolyamot köt össze, az egyik állományi megbízásokat (Orders), a másik az értékpapír-tranzakciók (Trades) eredményeit tartalmazza. A lekérdezés kimenete a megbízások folyama, amely megfeleltethető azokkal a tranzakciókkal, amelyek a rendelés leadása után 1 másodpercen belül történtek. A kimeneti adatfolyam a Rendelések tábla időbélyegei szerint van rendezve.
SELECT DataStream rendelések . Időbélyegző , Megrendelések . orderId , Orders . ticker , Megrendelések . összeg , Kereskedelem . összeg A megbízásoktól CSATLAKOZZ A TRADES OVER ( Tartmány ' 1' INTERVALLUM MÁSODIK KÖVETKEZÉS ) A megbízásokra . orderId = kereskedések . orderId ;Egy másik példa egy olyan kódrészlet, amely egy összetett eseményt, „esküvőt” észlel külső események folyamában, az események „harangozása”, egy szmokingos férfi és egy fehér ruhás menyasszony megjelenése, valamint a rizs következtében. levegőbe került, 2 órán belül megtörtént.
MIKOR Személy . A nem EGYENLŐ A " férfi" ÉS a személy . Ruhák EQUALS "szmoking " KÖVETÉSE - Személy . Ruhák EGYENLŐ "ruha" ÉS ( Church_Bell VAGY Rice_Flying ) 2 órán belül AKCIÓ Esküvő