Я пытаюсь запустить 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
Что я делаю не так?
