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

Question

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

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

Каждое вычисление - результат

Answer 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 в таблицу событий