메뉴 건너뛰기

Bigdata, Semantic IoT, Hadoop, NoSQL

Bigdata, 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;

}


}


A personal place to organize information learned during the development of such Hadoop, Hive, Hbase, Semantic IoT, etc.
We are open to the required minutes. Please send inquiries to gooper@gooper.com.

위로