关于SlipStream的问题


#1

insert into demo_table select e1.id,e2.letter from PATTERN(e1=demo_stream[e1.id>0] followby e2=demo_stream[e2.id=e1.id]) WITHIN (‘1’ minute);
以上是我建立streamjob的语句,在用pattern这种模式之前我测试过普通的是可以成功对接的,但用了上面的语句后我再在生产者里面输入
21,qqqqq
21,qweqe
这样数据是应该可以进去的吗。
还有,当我使用select /+ADHOC/ * from demo_stream;语句查询流表时,会一直不动,是我使用的方法不对吗?


#2

PATTERN是CEP语法中的关键字,从语法上来说数据应该可以进去,但用法通常是多事件组合。
对于select /+ADHOC/ * from demo_stream,morphling下adhoc不支持现在。


#3

好的,了解了,感谢!


在线支持