Ok, got it. No, the events are enriched based on the stored state information and emitted (per tuple).
On Mon, Sep 12, 2016 at 6:47 PM, Thomas Weise <[email protected]> wrote: > That documentation is not for Malhar. You find the user documentation for > Apex here: > > http://apex.apache.org/docs.html > > See links on top. > > So you want to enrich the data after it was emitted from the window? > > > > > On Mon, Sep 12, 2016 at 6:41 PM, Naresh Guntupalli < > [email protected]> wrote: > >> Thanks Ashwin and Thomas for your quick help. >> >> @Thomas: http://docs.datatorrent.com/operators/hdht/ - This is the doc >> I was referring to earlier. >> >> The use case is store and enrich certain user events in a (bigger) >> rolling window. >> >> -Naresh >> >> On Mon, Sep 12, 2016 at 5:43 PM, Thomas Weise <[email protected]> >> wrote: >> >>> Here is an example for the equivalent functionality in Malhar: >>> >>> https://github.com/apache/apex-malhar/blob/master/benchmark/ >>> src/main/java/com/datatorrent/benchmark/state/StoreOperator.java >>> >>> https://issues.apache.org/jira/browse/APEXMALHAR-2205 >>> >>> It will still be useful to understand the use case as there are also a >>> couple ready to use operators that use this state management facility. >>> >>> Thomas >>> >>> >>> On Mon, Sep 12, 2016 at 5:34 PM, Thomas Weise <[email protected]> >>> wrote: >>> >>>> Naresh, >>>> >>>> Which doc references this operator? Malhar has a replacement for this. >>>> Can you share some more info about your use case so that we can point you >>>> to the appropriate operator to start from? >>>> >>>> Thanks, >>>> Thomas >>>> >>>> >>>> On Mon, Sep 12, 2016 at 5:13 PM, Naresh Guntupalli < >>>> [email protected]> wrote: >>>> >>>>> The AbstractSinglePortHDHTWriter (HDHT) operator is missing from >>>>> Apex-Malhar 3.x releases, but the user docs still references it. Was the >>>>> operator removed or moved somewhere else? >>>>> >>>> >>>> >>> >> >
