【发布时间】:2019-09-19 06:41:13
【问题描述】:
我想使用 WSO2 流处理器将 CSV 文件转换为一组 Siddhi 事件,以便使用该 CSV 文件来训练 kmeansIncremental 模型。
我尝试使用“文件”作为源类型并使用“csv”作为地图类型来获取该 csv 文件,但是我做不到。
@source(type='file',file.uri='file:///home/Documents/Project%20Documents/logs/access.csv', @map(type='csv', header.present='true', event-grouping-enabled='true'))
define stream ProductionStream(latitude double, longitude double, frequency int, day int, timegap double, res_ratio double, client_id string);
我该怎么做?
【问题讨论】: