I’m trying to do some clustering algorithm for each hopping window. Meaning I have my windows ‘CepWindow<Payload>’ (CepWindowStream<CepWindow<Payload>>) and on that I would like to cluster all the items inside. For that I need access to
My idea was to build a user-defined aggregate do the clustering and produce an event (‘PayloadClusterResult’) as the result of the clustering and then give it to my output adapter.
I do not know how to solve this?
According to the documentation it is not possible to return a non-scalar value from a UDA.