protected void sendInBound ( int taskId , HeronTuples . HeronTupleSet message ) { if ( message . hasData ( ) ) { sendMessageToInstance ( taskId , message ) ; } if ( message . hasControl ( ) ) { processAcksAndFails ( message . getSrcTaskId ( ) , taskId , message . getControl ( ) ) ; } }
Send Stream to instance