Эспер последнее вставленное Событие

Question

Есть ли способ получить последнее вставленное событие в ядре esper до завершения правила?

Configuration cepConfig = new Configuration(); 
    cepConfig.getEngineDefaults().getMetricsReporting(). 
    setEnableMetricsReporting(true); 
cepConfig.addEventType("Stream", Stream.class.getName()); 
EPServiceProvider cep = EPServiceProviderManager.getProvider("myCEPEngine", cepConfig); 
EPRuntime cepRT = cep.getEPRuntime(); 
EPAdministrator cepAdm = cep.getEPAdministrator(); 
EPStatement cepStatement = cepAdm.createEPL("select * from Stream.win:length(100)") ; 
cepStatement.addListener(new CEPListener()); 

Теперь для вставки события я использую этот пример кода

for (int i = 0; i < 500; i++) { 
    GenerateRandomStream(cepRT); 
    //Here I want get the last inserted event 
} 

Любая помощь будет оценена.

Answer 1

Существует функция «prev», которую вы можете использовать. Что конкретно вы подразумеваете под «до завершения правила»?

Answer 2

Используйте по требованию API запросов, чтобы сделать один раз, запрос о времени выполнения двигателя Эспер в:

String query = "select prev(0, evt) from Stream.win:length(10) as evt"; 
EPOnDemandQueryResult result = cepRT.executeQuery(query);