code: def tz_convert_to_internal(s, t: DataType, local_tz):
      """
      Converts the timestamp series to internal according to the specified local timezone.
      """
      if type(t) == LocalZonedTimestampType:
          from pandas.api.types import (
              is_datetime64_dtype,
              is_datetime64tz_dtype,
          )
  
          if is_datetime64_dtype(s.dtype):
              return s.dt.tz_localize(None)
          elif is_datetime64tz_dtype(s.dtype):
              return s.dt.tz_convert(local_tz).dt.tz_localize(None)
      return s
  
file_path: flink/flink-python/pyflink/table/utils.py
imports: import ast
  from pyflink.common.types import RowKind
  from pyflink.java_gateway import get_gateway
  from pyflink.table.types import DataType, LocalZonedTimestampType, Row, RowType, TimeType, DateType, ArrayType, MapType, TimestampType, FloatType, RawType
  from pyflink.util.java_utils import to_jarray
  import datetime
  import pickle
label_desc: Use image node_id 4 for calling a global function with example usage: tz_convert_to_internal(s, t, local_tz) and returns: s, s, s