Siddhi CEP 3.x newbie Fragen

Question

Ich bin neu in Siddhi, und ich habe einige Fragen:

1. Ist SiddhiManager Thread-sicher? Ist es eine bewährte Methode, eine gemeinsame Instanz pro JVM zu verwenden?

2. Wie definiert man einen Stream und fügt eine Abfrage zur Laufzeit hinzu? Es scheint nur siddhiManager.createExecutionPlanRuntime (Plan), die eine neue ExecutionPlanRuntime Instanz erstellen wird. Und wie Stream und Abfrage neu zu definieren?

3. Was ist inEvents und removeEvents in QueryCallback?

    
   
   executionPlanRuntime.addCallback("query1", new QueryCallback() { 
        @Override 
        public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) { 
         EventPrinter.print(timeStamp, inEvents, removeEvents); 
        } 
       }); 
   

4. Wie würde Siddhi skalieren, wenn ich viele Streams und Abfragen habe?

Vielen Dank!

Answer 1

1. Ja. SiddhiManager ist Thread sicher und es ist eine gute Praxis, eine gemeinsame Instanz pro JVM zu haben. In der Tat wird Siddhi Manager in WSO2 CEP verwendet.
2. In Siddhi Stream Definition + Abfrage Kombination wird als Execution Plan betrachtet. Es gibt keine dedizierte Möglichkeit, einen Ausführungsplan auf der Siddhi-Ebene zu bearbeiten, außer das mit der createExecutionPlan-Methode erneut zu implementieren. Bitte beachten Sie, dass Sie dadurch ein neues ExecutionPlanRuntime-Objekt erhalten. Daher können alte Eingabe- Handler-Referenzen nicht wiederverwendet werden.
3. inEvents Array stellt Strom-Ereignisse, die von Siddhi emittiert und removeEvents repräsentieren abgelaufen-Ereignisse, die von Siddhi emittiert
4. Siddhi recht gut skalieren, wenn Sie viele Anfragen in Einzel Ausführungsplan haben. Aber beim Skalieren mit mehreren Ausführungsplänen wird Siddhi den Ressourcenschwellenwert schnell erreichen, da die Ressourcenauslastung pro Ausführungsplan wenig hoch ist, was zu einer Leistungsverschlechterung führt. Vor kurzem haben wir eine Verbesserung vorgenommen, um diese Einschränkung zu beheben, wie in dieser [1] Mail erläutert. Die Verbesserung ist in der Verzweigung des Masters verfügbar.

[1] http://wso2-oxygen-tank.10903.n7.nabble.com/Siddhi-Making-Disruptor-configurable-td136499.html