Учебники, представленные в потоковом процессоре wso2, не работают должным образом, особенно в режиме прогнозирования в реальном времени.

Question

Я пытаюсь воспроизвести учебное пособие «Создание прогнозов в реальном времени», приведенное в документации по потоковому процессору wso2, в котором прогнозируется, будет ли поставка отвечать требованиям с учетом температуры и плотности

Я использую предварительно обученный файл PMML (Sweet.pmml), приведенный в документации.

@App:name('SugerSyrupPredictionApp')

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

@sink(type='log', prefix='Predicted next sugar syrup shipment:')
define stream PredictedSugarSyrupDataStream (nextTemperature double, nextDensity double, decision bool);

from SugarSyrupDataStream#pmml:predict("/home/user/Sweet.pmml", temperature, density)
select *
insert into PredictedSugarSyrupDataStream;

Это ошибка, которую показывает Сиддхи, хотя код соответствует документации.

Другое определение, такое же как и выходной файл 'define stream PredictedSugarSyrupDataStream' (температура двойная, плотность двойная, ...), уже существует как '@sink (type = "log", prefix = "Прогнозируемая следующая отгрузка сахарного сиропа:" ) определить поток PredictedSugarSyrupStream (nextTength, double, ..., решение bool) '

Кстати, на вкладке страницы приветствия есть пример ( PmmlModelProcessor ), который работает нормально с использованием того же синтаксиса.