incubator-s4-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aboubakr Benabbas <aboubakr.benab...@tu-ilmenau.de>
Subject Re: 'enents between PE'
Date Fri, 31 May 2013 19:36:58 GMT


given the myApp exmaple, can you give me instructions how to add
another PE to take events from the HelloPE, if it can be modified and
what i should add to the app 

Matthieu Morel  schrieb: 

On May 30,
2013, at 21:25 , Aboubakr Benabbas wrote: 

hi, 

I would like to know
how can one implement PEs in a way, one PE outputs events that are
inputs for other PEs   PEs are connected through streams, and events
flow from PE to PE through those streams. So when creating the PE graph,
just make sure you have (down)streams created in PE prototypes and that
you use them for building the PE graph. 

For instance, in the twitter
counter example, the TopicExtractor PE can set a down stream:
https://github.com/apache/incubator-s4/blob/dev/test-apps/twitter-counter/src/main/java/org/apache/s4/example/twitter/TopicExtractorPE.java#L48
[1] 

and the set operation is performed when building the app graph:
https://github.com/apache/incubator-s4/blob/dev/test-apps/twitter-counter/src/main/java/org/apache/s4/example/twitter/TwitterCounterApp.java#L79
[2] 

Hope this helps, 

Matthieu 

 

Links:
------
[1]
https://github.com/apache/incubator-s4/blob/dev/test-apps/twitter-counter/src/main/java/org/apache/s4/example/twitter/TopicExtractorPE.java#L48
[2]
https://github.com/apache/incubator-s4/blob/dev/test-apps/twitter-counter/src/main/java/org/apache/s4/example/twitter/TwitterCounterApp.java#L79

Mime
View raw message