我正在尝试运行流处理器中的示例中存在的 RScriptSample。
我已按照此处给出的步骤进行操作。
我已经安装了 R 和 rJava，并相应地设置了 R_HOME 和 JRI_HOME。
@App:name("RScriptSample")
@App:description('Use a R script to process events and produce aggregated outputs based on the provided input variable parameters and expected output attributes.')
define stream weather (time long, temp double);
@sink(type='log')
define stream dataOut (time long, temp double, c long, m double );
@info(name = 'query')
from weather#window.lengthBatch(2)#r:eval("c <- sum(time); m <- sum(temp)", "c long, m double", time, temp)
select * insert into dataOut;
代码无法编译。我在最后一行收到此错误。
No extension exist for r:eval
我究竟做错了什么？