code: def test_data_types(self):
      import pandas as pd
  
      timezone = self.t_env.get_config().get_local_timezone()
      local_datetime = pytz.timezone(timezone).localize(
          datetime.datetime(1970, 1, 2, 0, 0, 0, 123000)
      )
  
      @udf(
          result_type=DataTypes.TIMESTAMP_WITH_LOCAL_TIME_ZONE(3),
          func_type="pandas",
      )
      def local_zoned_timestamp_func(local_zoned_timestamp_param):
          assert isinstance(local_zoned_timestamp_param, pd.Series)
          assert isinstance(
              local_zoned_timestamp_param[0], datetime.datetime
          ), "local_zoned_timestamp_param of wrong type %s !" % type(
              local_zoned_timestamp_param[0]
          )
          assert (
              local_zoned_timestamp_param[0] == local_datetime
          ), "local_zoned_timestamp_param is wrong value %s, %s!" % (
              local_zoned_timestamp_param[0],
              local_datetime,
          )
          return local_zoned_timestamp_param
  
      sink_table_ddl = """
          CREATE TABLE Results_test_data_types(a TIMESTAMP_LTZ(3)) WITH ('connector'='test-sink')
          """
      self.t_env.execute_sql(sink_table_ddl)
  
      t = self.t_env.from_elements(
          [(local_datetime,)],
          DataTypes.ROW(
              [
                  DataTypes.FIELD(
                      "a", DataTypes.TIMESTAMP_WITH_LOCAL_TIME_ZONE(3)
                  )
              ]
          ),
      )
  
      t.select(
          local_zoned_timestamp_func(local_zoned_timestamp_func(t.a))
      ).execute_insert("Results_test_data_types").wait()
      actual = source_sink_utils.results()
      self.assert_equals(actual, ["+I[1970-01-02T00:00:00.123Z]"])
  
imports: import datetime
  import decimal
  import pytz
  from pyflink.common import Row
  from pyflink.table import DataTypes
  from pyflink.table.tests.test_udf import SubtractOne
  from pyflink.table.udf import udf
  from pyflink.testing import source_sink_utils
  from pyflink.testing.test_case_utils import PyFlinkBatchTableTestCase, PyFlinkStreamTableTestCase, PyFlinkTestCase
label_desc: Use image node_id 4 for calling the PandasUDFITTests obj's underlying member method code with example usage: obj.test_data_types() and returns: local_zoned_timestamp_param