Как получить правила потока событий для расчета среднего

Question

Я пытаюсь заставить работать несколько базовых c примеров - чтобы я мог изучить и использовать их до начала реальной работы над проектом

У меня есть demoApp, который вставляет целочисленные факты в точку входа (Stream)

В Правилах (изначально) я просто пытаюсь «обнаружить» прибытие каждого нового события Integer, используя скользящее окно и накапливать функциональность, чтобы вычислить простое среднее значение за 3 тика (и вставить это как новые факты)

Примеры высоко ценится

Answer 1

Работает с этим правилом

package tradingRules

import java. sql .Date;

import tradingRules.model.historicData.StockQuote;

объявить дату SMA5: java. sql .Date @key Среднее: двойное окончание

объявить StockQuote @role (событие) end

объявить окно StockQuoteTicks StockQuote ( ) за окном: длина (5) от точки входа HistoricDataStream end

правило "вычислить 5 тиковых средних" диалект "mvel" 10, когда $ sQ: StockQuote ($ d1: date) от точки входа HistoricDataStream Number ($ s: doubleValue) из накопления ($ sQ2: StockQuote () из окна StockQuoteTicks, сумма ($ sQ2.close)), а затем insertLogical (новый SMA5 ($ d1, $ s / 5)); // System.out.println ("StockQuote 5 тиков в среднем" + $ s / 5); конец