incubator-s4-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From baojian Zhou <baojian.zhou.b...@gmail.com>
Subject about the createInputStream() in App.java
Date Fri, 05 Jul 2013 02:36:26 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message