class_docstr: Representing an Iterator that is also auto closeable.
class_docstr_tok: ["Representing","an","Iterator","that","is","also","auto","closeable","."]
code: def __init__(self, j_closeable_iterator, field_data_types):
      self._j_closeable_iterator = j_closeable_iterator
      self._j_field_data_types = field_data_types
      self._data_types = [
          _from_java_data_type(j_field_data_type)
          for j_field_data_type in self._j_field_data_types
      ]
  
imports: from typing import Optional
  from py4j.java_gateway import get_method
  from pyflink.common.types import RowKind
  from pyflink.common import Row
  from pyflink.common.job_client import JobClient
  from pyflink.java_gateway import get_gateway
  from pyflink.table.result_kind import ResultKind
  from pyflink.table.table_schema import TableSchema
  from pyflink.table.types import _from_java_data_type
  from pyflink.table.utils import pickled_bytes_to_python_converter
label_desc: Use image node_id 1 to create a new CloseableIterator object from inherited base classes: object with example: obj = CloseableIterator(j_closeable_iterator, field_data_types)