更新时间:2025-12-10 GMT+08:00
分享

Table APIs

insert(data, overwrite=False)

描述:用于将Dataset插入到数据库表中。

输入参数:

  • data (dataset.Dataset):要插入的Dataset对象,必须是fabric_data.multimodal.dataset.Dataset类型。
  • overwrite (bool):是否覆盖已存在的数据,默认为False。

返回值类型:None

show(limit=10)

描述:用于显示表的前N行数据。

输入参数:

limit(int) - 限制输出的行数,默认为10。

返回值类型:None

to_dataset()

描述:将当前表对象转换为Dataset对象。

输入参数:无

返回值类型:Dataset

add_columns(new_cols)

描述:向表中添加一个或多个新列。

输入参数:

new_cols (Dict[str, str]) :要添加的列的字典,键为列名(str),值为列类型(str)。

返回值类型:None

drop_columns(*columns)

描述:用于从表中删除一个或多个列。

输入参数:

*columns (str):要删除的列名,可以是多个字符串参数。

返回值类型:None

alter_column_type(column_name, new_type)

描述:修改表中指定列的数据类型。

输入参数:

  • column_name (str) :要修改类型的列名。
  • new_type (str) : 新的数据类型名称。

返回值类型:None

rename_column(column_name, new_name)

描述:重命名表中的列名。

输入参数:

  • column_name (str) : 当前列名。
  • new_type (str) : 新列名。

返回值类型:None

delete(where)

描述:从表中删除满足指定条件的数据。

输入参数:

where (str) - SQL WHERE子句:用于指定删除条件。

返回值类型:None

update(values_expr, where)

描述:更新表中满足指定条件的行数据。

输入参数:

  • values_expr (Dict[str, ValueExpression]) :键为列名(str),值为用于更新该列的表达式(ValueExpression)。
  • where (Union[ir.BooleanValue, list[ir.BooleanValue], IfAnyAll, None]) :用于过滤要更新的行的条件。如果为None,则更新所有行。

返回值类型:None

相关文档