2016-10-03 4 views
1

가 포함되어 있습니다. 다음 이벤트를 보내주십시오.호출 방법은 모두 내가</p> <pre><code>select udf(a,b) from Event.win:length_batch(5) </code></pre> <p>같은 방법을 호출하고 밖으로 다시 크기 5의 창을 인쇄 할 수있는 방법은 이벤트

runtime.sendEvent(new Event(1,2)); 
runtime.sendEvent(new Event(3,4)); 
runtime.sendEvent(new Event(4,2)); 
runtime.sendEvent(new Event(6,8)); 
runtime.sendEvent(new Event(4,6)); 

일괄 처리 한 후 동일한 순서로 출력하십시오. 즉, 호출 된 메소드 udf (a, b)는 배치 당 한 번만 실행됩니다. updatelistener를 사용했지만 리스너를 사용하여 원하는 결과를 얻을 수 있지만 메서드 이벤트로 호출해야합니다.

감사합니다.

답변

1

"구독자"를 찾고 있다고 생각합니다.

Subscribers in doc

public void update(Event[] rows) {...} 
+0

편집 : 나는 그것의 alsmot에게 리스너를 추가하는 것과 같은 방법을 참조하십시오. 나는 그 동안 그것을 시험 할 것이다. 감사합니다 – wandapong

+0

하지만 setSubscriber (sub) 때 update() 메서드가 호출됩니다? 이것은 청취자를 설정하는 것과 거의 같습니다. 내가 원하는 것은 구독자로 설정할 필요없이 내 쿼리에서 업데이트 (Event [] new, Event [] old) 메서드로 가능한 작업을 수행하도록 지정된 메서드입니다. 업데이트 방법은 기본적으로 updatelistener와 동일하지 않습니까? – wandapong