來自Hazelcast的事件表

Question

我正在使用下面的執行計劃來填充我的hazelcast支持的事件表。 問題是，如何從其他執行計劃重用此現有的支持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; 

執行計劃2

@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;