code: private void cleanupQueryStates() {
          completeRequestSpan(currentRequest());
          finishedDecoding();
          queryInfoObservable = null;
          queryRowObservable = null;
          queryErrorObservable = null;
          queryStatusObservable = null;
          querySignatureObservable = null;
          queryParsingState = QUERY_STATE_INITIAL;
      }
docs: Clean up the query states after all rows have been consumed.