code: def test_to_pandas_with_event_time(self):
      self.t_env.get_config().set("parallelism.default", "1")
      # create source file path
      import tempfile
      import os
  
      tmp_dir = tempfile.gettempdir()
      data = [
          "2018-03-11 03:10:00",
          "2018-03-11 03:10:00",
          "2018-03-11 03:10:00",
          "2018-03-11 03:40:00",
          "2018-03-11 04:20:00",
          "2018-03-11 03:30:00",
      ]
      source_path = tmp_dir + "/test_to_pandas_with_event_time.csv"
      with open(source_path, "w") as fd:
          for ele in data:
              fd.write(ele + "\n")
  
      self.t_env.get_config().set(
          "pipeline.time-characteristic", "EventTime"
      )
  
      source_table = (
          """
              create table source_table(
                  rowtime TIMESTAMP(3),
                  WATERMARK FOR rowtime AS rowtime - INTERVAL '60' MINUTE
              ) with(
                  'connector.type' = 'filesystem',
                  'format.type' = 'csv',
                  'connector.path' = '%s',
                  'format.ignore-first-line' = 'false',
                  'format.field-delimiter' = ','
              )
          """
          % source_path
      )
      self.t_env.execute_sql(source_table)
      t = self.t_env.from_path("source_table")
      result_pdf = t.to_pandas()
      import pandas as pd
  
      os.remove(source_path)
      assert_frame_equal(
          result_pdf,
          pd.DataFrame(
              data={
                  "rowtime": [
                      datetime.datetime(2018, 3, 11, 3, 10),
                      datetime.datetime(2018, 3, 11, 3, 10),
                      datetime.datetime(2018, 3, 11, 3, 10),
                      datetime.datetime(2018, 3, 11, 3, 40),
                      datetime.datetime(2018, 3, 11, 4, 20),
                      datetime.datetime(2018, 3, 11, 3, 30),
                  ]
              }
          ),
      )
  
imports: import datetime
  import decimal
  from pandas.testing import assert_frame_equal
  from pyflink.common import Row
  from pyflink.table.types import DataTypes
  from pyflink.testing import source_sink_utils
  from pyflink.testing.test_case_utils import PyFlinkBatchTableTestCase, PyFlinkStreamTableTestCase
label_desc: Use image node_id 1 for calling the StreamPandasConversionTests obj's underlying member method code with example usage: obj.test_to_pandas_with_event_time() without return types