flink-siddhi当前不支持完整的siddhi功能和扩展?

[runc]

当前我想实现一个UI+siddhiEngine，功能对其siddhi-distribution + runner，其中runner用flink代替，但flink-siddhi支持实现一部分siddhi或者product-sp功能？

flink-siddhi如何支持完整的siddhi功能呢？比如:

@Source(type = 'http', receiver.url='http://localhost:8006/productionStream', basic.auth.enabled='false', @map(type='json')) define stream SweetProductionStream (name string, amount double);

@sink(type='log') define stream TotalCountStream (totalCount long);

-- Count the incoming events @info(name='query1') from SweetProductionStream select count() as totalCount insert into TotalCountStream;

[haoch]

flink-siddhi mainly focus on managing siddhi (programming/dynamical) inside flink distributed runtime. it should natively support all siddhi existing function and extension. For example, siddhi could easily discover all extension once in classpath.

[runc]

thanks