question: protected void processTuple ( T tuple ) { Future < Slice > valFuture = getAsyncManagedState ( tuple ) ; if ( valFuture . isDone ( ) ) { try { processEvent ( tuple , valFuture . get ( ) ) ; } catch ( InterruptedException | ExecutionException e ) { throw new RuntimeException ( e ) ; } } else { processWaitingEvent ( tuple , valFuture ) ; } }
target:  Processes an incoming tuple