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 <hitesh.go...@nlpcaptcha.com> Reply-To: <users@apex.apache.org> Date: Tuesday, September 6, 2016 at 1:00 AM To: "users@apex.apache.org" <users@apex.apache.org> 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
