Hazelcast의 이벤트 테이블

Question

아래의 실행 계획을 사용하여 헤이 필드 캐스트 이벤트 테이블을 채 웁니다. 문제는, 어떻게이 기존의 hazelcast 지원 이벤트 테이블을 다른 실행 계획에서 재사용 할 수 있습니까?

또 다른 similar question에 대한 후속 질문입니다.

@Import('users:1.0.0') 
define stream users (meta_name string, correlation_id int); 

@from(eventtable = 'hazelcast', cluster.name = 'cluster_a', cluster.password = 'pass@cluster_a') 
define table UserTable (name string, id int) ; 

from users 
select meta_name as name, correlation_id as id 
insert OVERWRITE UserTable 
    on UserTable.id == id; 

Answer 1

두 실행 계획에서 모두 collection.name을 사용할 수 있습니다. cluster.name 및 cluster.password을 사용할 필요가 없습니다. 다음 예제를 참조하십시오.

실행 계획 1

@Plan:name('TestIn') 

@Import('dataIn:1.0.0') 
define stream dataIn (id int, name string); 

@from(eventtable = 'hazelcast', collection.name='hzTable') 
define table hzTable (id int, name string); 

from dataIn 
insert into hzTable; 

실행 계획

@Plan:name('TestOut') 

@Export('dataOut:1.0.0') 
define stream dataOut (id int, name string); 

@from(eventtable = 'hazelcast', collection.name='hzTable') 
define table hzTable (id int, name string); 

define trigger periodicTrigger at every 2 sec; 

from periodicTrigger join hzTable 
select hzTable.id as id, hzTable.name as name 
insert into dataOut;