Hi Georg,

It still doesn't support state access in Python API in the latest version 1.11. 

Could you take a look at if KeyedProcessFunction could meet your requirements? 
We are planning to support it in Python DataStream API in 1.12.

Regards,
Dian

> 在 2020年9月9日,下午2:28,Georg Heiler <georg.kf.hei...@gmail.com> 写道:
> 
> Hi,
> 
> does the python API expose some kind of mapGroupsWithState operator which can 
> be applied on a window to handle arbitrary state?
> 
> I would want to perform time-series anomaly detection using a streaming 
> implementation of the matrix profile algorithm using 
> https://github.com/TDAmeritrade/stumpy 
> <https://github.com/TDAmeritrade/stumpy> There would be multiple instances of 
> matrix profile, one for each group.
> 
> Best,
> Georg

Reply via email to