# UDTF
UDTF是输入一行返回多行的函数，适用于典型的多模态数据处理场景，包括视频/音频切帧，样本生成等。UDTF具体的定义和使用约束请参考[UDTF](https://support.huaweicloud.com/devg-fabric/dataartsfabric_sql_04_0197.html)。
#### 示例
以下示例展示UDTF的注册和使用的流程。
1. 创建会话。
   ```
   import ibis
   import fabric_data as fabric
   import logging
   # create session
   con = ai_lake.connect(...)
   ```
   
2. 定义并注册UDTF。
   ```
   # function definition
   def py_generate_series(start, endnum, step):
       current = start
       while current <= endnum:
           yield {'col1':current}
           current += step
   # register udtf
   import ibis.expr.datatypes as dt
   func_signature=fabric.Signature(
        parameters=[
            fabric.Parameter(name="start", annotation=int),
            fabric.Parameter(name="endnum", annotation=int),
            fabric.Parameter(name="step", annotation=int)
        ],
        return_annotation=dt.Struct({"col1": int}),
   )
   target_database = 'test'
   con.create_table_function(py_generate_series, database=target_database, signature=func_signature)
   ```
   
3. 调用UDTF。
   ```
   # use udtf
   ds = con.load_dataset("demo_table", database=target_database)
   py_generate_series_handler = con.get_function("py_generate_series", database=target_database)
   ds = ds.flat_map(
      fn=py_generate_series_handler,
      on=[ds.a, ds.b, ds.c],
      as_col='udtf_col'
   )
   # trigger executing
   res = ds.execute()
   print(res)
   | a     | b     | c     | udtf_col |
   | ----- | ----- | ----- | -------- |
   | int64 | int64 | int64 | int64    |
   | ----- | ----- | ----- | -------- |
   | 1     | 4     | 1     | 1        |
   | 1     | 4     | 1     | 2        |
   | 1     | 4     | 1     | 3        |
   | 1     | 4     | 1     | 4        |
   ```