void function ( ) { valid = false ; queue . clear ( ) ; while ( ! queue . offer ( END ) ) { if ( queue . poll ( ) == null ) { if ( Log . debugEnabled ( ) ) { Log . debug ( "srini_string" + executor . statement . taskId + "srini_string" ) ; } break ; } } }
abort retrieval with end token . concode_field_sep Integer END concode_elem_sep boolean valid concode_elem_sep QueryAggregateExecutor executor concode_elem_sep Object row concode_elem_sep BlockingQueue<Object> queue concode_elem_sep ResultSet resultSet concode_field_sep boolean next concode_elem_sep Object next concode_elem_sep Iterator<Object> iterator concode_elem_sep Object getObject concode_elem_sep boolean hasNext concode_elem_sep void close concode_elem_sep void close concode_elem_sep boolean put concode_elem_sep void remove