Many thanks. This is great to hear. Yes! This looks great.
Many Thanks! Best, Georg Am Do., 10. Sept. 2020 um 23:53 Uhr schrieb Dian Fu <dian0511...@gmail.com>: > 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 There would be multiple instances > of matrix profile, one for each group. > > Best, > Georg > > >