class_docstr: A test retract table sink.
code: def __init__(self, field_names, field_types):
      TestTableSink._ensure_initialized()
      gateway = get_gateway()
      j_field_names = java_utils.to_jarray(
          gateway.jvm.String, field_names
      )
      j_field_types = java_utils.to_jarray(
          gateway.jvm.DataType,
          [
              _to_java_data_type(field_type)
              for field_type in field_types
          ],
      )
      super(TestRetractSink, self).__init__(
          gateway.jvm.org.apache.flink.table.utils.TestingSinks.TestAppendingSink(
              j_field_names, j_field_types
          )
      )
  
imports: import glob
  import os
  import unittest
  from py4j.java_gateway import java_import
  from pyflink.find_flink_home import _find_flink_source_root
  from pyflink.java_gateway import get_gateway
  from pyflink.table.sinks import TableSink
  from pyflink.table.types import _to_java_data_type
  from pyflink.util import java_utils
label_desc: Use image node_id 1 to create a new TestRetractSink object from inherited base classes: TestTableSink with example: obj = TestRetractSink(field_names, field_types)