2016-12-18 3 views
0

내 질문은 이와 같습니다. 저는 초당 실시간 데이터에 대한 데이터 소스 액세스를 정의합니다. 평균 계산을 위해이 일괄 처리 데이터를 시간당 평균으로 계산하고 평균 시간당 데이터 그룹을 갖습니다. 누적 합계, 마지막으로 한 시간의 누적 값을 다른 데이터 원본에 저장합니다. 평균 값은 10 시간이고 데이터 원본에 10을 부여하고 두 번째 시간 평균은 20이며 그 다음에 1 시간을 더합니다 평균 10 출력 30, 하루 24 시간의 끝에, 첫 번째 시간에서 두 번째 날이 계산됩니다. 문제는 어떻게 지금, 내가 누적 값을 계산하는 마지막 시간을 캐시 할 수있는 방법입니다 해결 방법 비슷한 문제? 예 : enter image description here어떻게 wso2 siddhiQL 캐시 데이터를 사용할 수 있습니까?

평균 데이터 열에서 상기 화상이 instream_ #의 window.externalTimeBatch (날짜, 1 시간) 얻을 수 통해 I 인 것처럼 열 후면의 출력 결과 시간당, 나는 생각한다. 이 같은 : enter image description here

마다 그 결과 당신은 포스트 그레스/MySQL은/​​오라클과 같은 관계형 데이터베이스의 데이터를 캐시 이벤트 표를 사용하여 출력

답변

0

입니다 계산합니다.

주먹 데이터베이스에서 테이블을 정의 :

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

및 스트림 시간에 도달하면, 당신은 이벤트 테이블에 0.0을 덮어 삽입 할 수 있습니다