this method is responsible for failing specified inputs . the default method does no-operation . concode_field_sep ExecutionResultHandler handler concode_elem_sep ConcurrentLinkedQueue<ExecutionResultCollector> completed concode_field_sep void flush concode_elem_sep void success
void function ( Throwable arg0 , Tuple arg1 ) { completed . offer ( new ExecutionResultCollector . FailedCollector ( arg1 , arg0 ) ) ; }