Я хочу преобразовать CSV-файл в набор событий Siddhi с помощью потокового процессора WSO2, чтобы использовать этот CSV-файл для обучения модели kmeansIncremental.
Я пытался найти этот CSV-файл с помощью 'file'как тип источника и' csv 'как тип карты, но я не смог этого сделать.
@source(type='file',file.uri='file:///home/Documents/Project%20Documents/logs/access.csv', @map(type='csv', header.present='true', event-grouping-enabled='true'))
определить поток ProductionStream (двойная широта, двойная долгота, частота int, день int, двойной интервал времени, res_ratiodouble, client_id string);
Как я могу это сделать?