class_docstr: A util class to collect test DataStream transformation results.
code: def __init__(self):
      self.j_data_stream_collect_sink = (
          get_gateway().jvm.org.apache.flink.python.util.DataStreamTestCollectSink()
      )
      super(DataStreamTestSinkFunction, self).__init__(
          sink_func=self.j_data_stream_collect_sink
      )
  
imports: import pickle
  from pyflink.datastream.functions import SinkFunction
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 1 to create a new DataStreamTestSinkFunction object from inherited base classes: SinkFunction with example: obj = DataStreamTestSinkFunction()