как я могу использовать данные кэша wso2 siddhiQL?

Мой вопрос такой: я определяю доступ источника данных к данным в реальном времени в секунду (имеет), я буду использовать этот пакет данных в час для среднего расчета, а затем получить эту группу данных за час средней накопительной суммы , наконец, поместите кумулятивное значение часа в другой источник данных. Так как среднее значение равно 10 1 час, я дам 10 источнику данных, среднее значение второго часа равно 20, затем я добавлю в среднем 1 час 10 вывод 30, и так далее, до конца 24 часов в сутки вычисляется второй день после первого часа. Теперь проблема в том, как я могу кэшировать последний раз, когда я вычисляю совокупные значения, как решить аналогичную проблему ? например: введите здесь описание изображения

Как и на картинке выше, в столбце средних данных я могу получить через instream_ # window.externalTimeBatch (datetime, 1 час), в конце столбца, я думаю, результат вывода за час. вот так: введите здесь описание изображения

Результат каждого вычисления выводится


person zuoxb    schedule 18.12.2016    source источник


Ответы (1)


Вы можете использовать таблицу событий для кэширования данных в базе данных отношений, например postgres / mysql / oracle.

Кулак определить таблицу из базы данных:

@From(eventtable='rdbms', datasource.name='db_event', table.name='_tag_time_value')
define table tEvent (tag string, datetime long , value double);

и если время потока достигнет, вы можете вставить перезапись 0.0 в таблицу событий

person yeahliu    schedule 19.12.2016