В потоковом процессоре WSO2 при обнаружении аномалии возникает исключение

Question

Я пытаюсь воспроизвести учебное пособие «Обнаружение аномалий», приведенное в документации по потоковому процессору WSO2.

@App:name('SugarSyrupOutlierPredictionApp')

@source(type='http', receiver.url='http://localhost:5007/SugarSyrupEP', @map(type = 'json'))
define stream SugarSyrupDataStream (viscosity double, temperature double, density double);

@sink(type='log', prefix='Outlier detected in sugar syrup supply:')
define stream OutlierStream (viscosity double, temperature double, density double, outlier bool);

from SugarSyrupDataStream#timeseries:outlier(5, viscosity, temperature, density)
select *
insert into OutlierStream;

Ошибка, которую я получаю в строке, в которой я вызываю свою функцию выброса, заключается в следующем.

Caused by: org.wso2.siddhi.core.exception.SiddhiAppCreationException: Outlier Function is available only for simple linear regression at org.wso2.extension.siddhi.execution.timeseries.LinearRegressionOutlierStreamProcessor.init(LinearRegressionOutlierStreamProcessor.java:221)

Я что-то здесь упускаю или я должен использовать какую-то другую функцию?

Answer 1

Кажется, расширение принимает только 3 параметра.Пожалуйста, обратитесь к документации siddhi-execute-timeseries # outlier .

Вам необходимо обновить учебный образец, чтобы диапазон, Y и X были параметрами для расширения outlier.Это потому, что расширение поддерживает только простые линейные регрессии.

@App:name('SugarSyrupOutlierPredictionApp')

@source(type='http', receiver.url='http://localhost:5007/SugarSyrupEP', @map(type = 'json'))
define stream SugarSyrupDataStream (viscosity double, temperature double, density double);

@sink(type='log', prefix='Outlier detected in sugar syrup supply:')
define stream OutlierStream (viscosity double, temperature double, outlier bool);

from SugarSyrupDataStream#timeseries:outlier(5, viscosity, temperature)
select viscosity, temperature, outlier
insert into OutlierStream;