hi everybody
there is a method called createInputStream(String streamName, KeyFinder<T>
finder, ProcessingElement... processingElements) in the App.java
if i want to use it like this:
createInputStream("inputStream" , keyFinder, simplePE1).setParallelism(1);
and it is OK.
but if i want to add another PE object to inputStream dynamically after
invoked this method, how can i do it?
thank you
