The classes are ultimately subclasses of com.datatorrent.lib.db.AbstractTransactionableStoreOutputOperator<T, S> and that class defines the input port thus
/** * The input port on which tuples are received for writing. */ @InputPortFieldAnnotation(optional = true) public final transient DefaultInputPort<T> input = new DefaultInputPort<T>() …. From: Hitesh Goyal <[email protected]> Reply-To: <[email protected]> Date: Tuesday, September 6, 2016 at 1:00 AM To: "[email protected]" <[email protected]> Subject: Write data to couchbase Hi team, I want to write data to my couchbase. I tried to use AbstractCouchBaseOutputOperator and CouchBasePojoSetOperator. I want to know where should I input the data because I am not able to find any input port or so where I can get the data in. Please tell how can I do that. Regards, Hitesh Goyal Simpli5d Technologies Cont No.: 9599803307
