来自 Hazelcast 的活动 table

Question

我正在使用以下执行计划来填充我的 hazelcast 支持事件 table。问题是，如何从另一个执行计划中重用这个现有的 hazelcast 支持事件 table？

这是另一个的后续问题。

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

来自 Hazelcast 的活动 table

Event table from Hazelcast

wso2

hazelcast

wso2cep