Looks like you are trying to create an Operator that has multiple input sources and multiple output sinks. For this specific question, I guess you want to have 2 DefaultOutputPort. So you can try the following in the JdbcPojooutput operator.
final transient DefaultOutputPort <String> op1 = new DefaultOutputPort<>(); final transient DefaultOutputPort <String> op2 = new DefaultOutputPort<>(); And in the StreamingApplication, specify the streams using op1 and op2 to respective sinks. On Tue, Jul 12, 2016 at 9:19 AM, Jaikit Jilka <[email protected]> wrote: > Hello, > > In my application I am using JdbcPojooutput operator and JdbcPojoInput > operator. I was thinking whether we can have multiple output for > JdbcPojoInput operator as currently I am using 2 JdbcPojoInput operator. I > tried to do so but I got error. So I want to know can we do that? > > Thank You, > > Jaikit Jilka >
