CepWindowStream<CepWindow<Payload>> Hopping Window UDA


  • Hello guys,

    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 payload.

    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.

    Friday, July 11, 2014 12:05 PM


  • Try using a User Defined Operator (UDO) instead. Like a UDA, a UDO will operate on a window. Unlike a UDA, with a UDO you get the entire payload and you can return a complex result.

    DevBiker (aka J Sawyer)
    Microsoft MVP - Sql Server (StreamInsight)

    Ruminations of

    If I answered your question, please mark as answer.
    If my post was helpful, please mark as helpful.

    Tuesday, July 15, 2014 12:18 AM