code: def test_from_element_expression(self):
      t_env = self.t_env
  
      field_names = ["a", "b", "c"]
      field_types = [
          DataTypes.BIGINT(),
          DataTypes.STRING(),
          DataTypes.FLOAT(),
      ]
  
      schema = DataTypes.ROW(
          list(
              map(
                  lambda field_name, field_type: DataTypes.FIELD(
                      field_name, field_type
                  ),
                  field_names,
                  field_types,
              )
          )
      )
      sink_table_ddl = """
              CREATE TABLE Results_test_from_element_expression(a BIGINT, b STRING, c FLOAT)
              WITH ('connector'='test-sink')
          """
      self.t_env.execute_sql(sink_table_ddl)
  
      t = t_env.from_elements(
          [row(1, "abc", 2.0), row(2, "def", 3.0)], schema
      )
      t.execute_insert("Results_test_from_element_expression").wait()
      actual = source_sink_utils.results()
  
      expected = ["+I[1, abc, 2.0]", "+I[2, def, 3.0]"]
      self.assert_equals(actual, expected)
  
file_path: flink/flink-python/pyflink/table/tests/test_calc.py
imports: import array
  import datetime
  from decimal import Decimal
  from pyflink.common import Row
  from pyflink.table import DataTypes
  from pyflink.table.expressions import row
  from pyflink.table.tests.test_types import PythonOnlyPoint, PythonOnlyUDT
  from pyflink.testing import source_sink_utils
  from pyflink.testing.test_case_utils import PyFlinkStreamTableTestCase
label_desc: Use image node_id 6 for calling the StreamTableCalcTests obj's underlying member method code with example usage: obj.test_from_element_expression() without return types