r:eval 不存在扩展

Question

我正在尝试运行流处理器中样本中存在的 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

我做错了什么？

Answer 1

由于此扩展在 GPL 扩展下，因此默认情况下不会将其复制到包中。将 jar 添加到 {SP_HOME}/lib 文件夹并试用示例。兼容版本：4.x.x