code: def conversion_from_dataframe():
      t_env = TableEnvironment.create(
          EnvironmentSettings.in_streaming_mode()
      )
      t_env.get_config().set("parallelism.default", "1")
  
      # define the source with watermark definition
      pdf = pd.DataFrame(np.random.rand(1000, 2))
      table = t_env.from_pandas(
          pdf,
          schema=DataTypes.ROW(
              [
                  DataTypes.FIELD("a", DataTypes.DOUBLE()),
                  DataTypes.FIELD("b", DataTypes.DOUBLE()),
              ]
          ),
      )
  
      print(table.to_pandas())
  
imports: import logging
  import sys
  import pandas
  import numpy
  from pyflink.table import DataTypes, TableEnvironment, EnvironmentSettings
label_desc: Use image node_id 1 for calling a global function with example usage: conversion_from_dataframe() without return types