class_docstr: A util class to collect test DataStream transformation results.
code: def get_results(
      self, is_python_object: bool = False, stringify: bool = True
  ):
      j_results = self.get_java_function().collectAndClear(
          is_python_object
      )
      results = list(j_results)
      if not is_python_object:
          return results
      else:
          str_results = []
          for result in results:
              pickled_result = pickle.loads(result)
              if stringify:
                  str_results.append(str(pickled_result))
              else:
                  str_results.append(pickled_result)
          return str_results
  
imports: import pickle
  from pyflink.datastream.functions import SinkFunction
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 2 for calling the DataStreamTestSinkFunction obj's underlying member method code with example usage: obj.get_results(is_python_object, stringify) and returns: results, str_results