void function ( DefaultOutputPort < T > arg0 , final DefaultInputPort < T > arg1 ) { arg0 . setSink ( new Sink < Object > ( ) { @ Override @ SuppressWarnings ( "srini_string" ) public void put ( Object arg2 ) { LOG . debug ( "srini_string" ) ; arg1 . process ( ( T ) arg2 ) ; } @ Override public int getCount ( boolean arg2 ) { return 0 ; } } ) ; }
this is a utility method which is used to attach the output port of an embeddablequeryinfoprovider to the input portof the encapsulating appdata.store . concode_field_sep BufferingOutputPort<TUPLE_TYPE> port concode_elem_sep Logger LOG concode_field_sep void run