Я пытаюсь воспроизвести учебное пособие «Создание прогнозов в реальном времени», приведенное в документации по потоковому процессору 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 ), который работает нормально с использованием того же синтаксиса.