Cloudera CDH/CDP 및 Hadoop EcoSystem, Semantic IoT등의 개발/운영 기술을 정리합니다. gooper@gooper.com로 문의 주세요.
-------------------CustomViewChangedEventListener.java----------------
package com.gooper.drool_test;
import java.util.ArrayList;
import java.util.List;
import org.kie.api.runtime.rule.Row;
import org.kie.api.runtime.rule.ViewChangedEventListener;
/*
* 쿼리 변경 이벤트를 처리하기 위한 구현체
*/
public class CustomViewChangedEventListener implements ViewChangedEventListener {
private List<ServerInfo> updatedServers;
private List<ServerInfo> deletedServers;
private List<ServerInfo> currentServers;
public CustomViewChangedEventListener() {
updatedServers = new ArrayList<ServerInfo>();
deletedServers = new ArrayList<ServerInfo>();
currentServers = new ArrayList<ServerInfo>();
}
@Override
public void rowDeleted(Row row) {
deletedServers.add((ServerInfo)row.get("$server_info"));
}
@Override
public void rowInserted(Row row) {
currentServers.add((ServerInfo)row.get("$server_info"));
}
@Override
public void rowUpdated(Row row) {
updatedServers.add((ServerInfo)row.get("$server_info"));
}
public List<ServerInfo> getUpdatedServers() {
return updatedServers;
}
public List<ServerInfo> getDeletedServers() {
return deletedServers;
}
public List<ServerInfo> getCurrentServers() {
return currentServers;
}
}
댓글 0
번호 | 제목 | 날짜 | 조회 수 |
---|---|---|---|
11 | How-to: Build a Complex Event Processing App on Apache Spark and Drools | 2016.10.31 | 548 |
10 | 슬라이딩 윈도우 예제 | 2016.07.28 | 295 |
9 | 거침없이 배우는 Drools 책의 샘플소스 | 2016.07.22 | 1507 |
8 | drools를 이용한 로그,rule matching등의 테스트 java프로그램 | 2016.07.21 | 294 |
7 | ServerInfo객체파일 | 2016.07.21 | 1165 |
6 | drools에서 drl관련 로그를 기록하기 위한 클래스 파일 | 2016.07.21 | 870 |
5 | 워킹 메모리에 대한 정보를 처리하는 클래스 파일 | 2016.07.21 | 954 |
» | 커리 변경 이벤트를 처리하기 위한 구현클래스 | 2016.07.21 | 870 |
3 | 룰에 매칭되면 발생되는 엑티베이션 객체에 대한 작업(이전값 혹은 현재값)을 처리하는 클래스 파일 | 2016.07.21 | 465 |
2 | 실시간 쿼리 변환 모니터링(팩트내 필드값의 변경사항을 실시간으로 추적함)하는 테스트 java 프로그램 | 2016.07.21 | 212 |
1 | Drools 6.0 - 비즈니스 룰 기반으로 간단한 룰 애플리케이션 만들기 | 2016.07.18 | 1043 |