code: def test_basic_functionality(self):
      # pandas UDF
      add_one = udf(
          lambda i: i + 1,
          result_type=DataTypes.BIGINT(),
          func_type="pandas",
      )
  
      # general Python UDF
      subtract_one = udf(
          SubtractOne(), DataTypes.BIGINT(), DataTypes.BIGINT()
      )
  
      sink_table_ddl = """
          CREATE TABLE Results_test_basic_functionality(
              a BIGINT,
              b BIGINT,
              c BIGINT,
              d BIGINT
          ) WITH ('connector'='test-sink')
          """
      self.t_env.execute_sql(sink_table_ddl)
  
      t = self.t_env.from_elements(
          [(1, 2, 3), (2, 5, 6), (3, 1, 9)], ["a", "b", "c"]
      )
      t.where(add_one(t.b) <= 3).select(
          t.a,
          t.b + 1,
          add(t.a + 1, subtract_one(t.c)) + 2,
          add(add_one(t.a), 1),
      ).execute_insert("Results_test_basic_functionality").wait()
      actual = source_sink_utils.results()
      self.assert_equals(actual, ["+I[1, 3, 6, 3]", "+I[3, 2, 14, 5]"])
  
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 1 for calling the PandasUDFITTests obj's underlying member method code with example usage: obj.test_basic_functionality() without return types