getCEPEngineStat

getCEPEngineStat(engine)

Check the status of a specific CEP engine.

engine is the engine object returned by createCEPEngine.

It returns a dictionary containing the following keys:

• EngineStat: a dictionary with the info of engine status (same as the returned info as getStreamEngineStat().CEPEngine).

• eventSchema: a table with the info of all events received.

• subEngineStat: a table with the info of sub-engine status.

• dataViewEngines: a table with the info of data view engines' status.

class Orders{
    eventTime :: TIMESTAMP 
    sym :: STRING
    val0 :: INT
    val1 :: FLOAT
    val2 :: DOUBLE
    def Orders(s,v0,v1,v2){
        sym = s
        val0 = v0
        val1 = v1
        val2 = v2
        eventTime = now()
    }
}
class mainMonitor:CEPMonitor {
    ordersTable :: ANY 
    def mainMonitor(){
        ordersTable = array(ANY, 0)  
    }    

    def updateOrders(event) {
        ordersTable.append!([event.sym, event.val0, event.val1, event.val2])
    }
    def onload(){
        addEventListener(updateOrders, 'Orders',,'all') 
    }
}
dummy = table(array(TIMESTAMP, 0) as eventTime,array(STRING, 0) as eventType,  array(BLOB, 0) as blobs)
engine=createCEPEngine(name="cep_engine",monitors=<mainMonitor()>,dummyTable=dummy,eventSchema=Orders,timeColumn='eventTime')

appendEvent(`cep_engine,Orders("a000", 3, 3.0, 30.0))

getCEPEngineStat(`cep_engine)

Related functions: createCEPEngine, dropStreamEngine