更新时间:2026-10-08 GMT+08:00
I/O APIs
write_iceberg(target_name, database, create_if_not_exists=False, overwrite=False, is_external=False, schema=None)
描述:将数据写入指定的Iceberg表中。
输入参数:
- target_name (str) :目标表的名称。
- database (str) :表所属的数据库。
- create_if_not_exists (bool) :如果为True,当表不存在时将自动创建该表。
- overwrite (bool):如果为True,将覆盖表中现有的数据。
- is_external (bool) :如果为True,将表视为外部表。
- schema(可选,任意类型):表的结构定义,可选参数。
返回值类型:None
write_orc(target_name, database, create_if_not_exists=False, overwrite=False, is_external=False, schema=None)
描述:将数据写入指定的ORC表中。
输入参数:
- target_name (str) :目标表的名称。
- database (str) :表所属的数据库。
- create_if_not_exists (bool) :如果为True,当表不存在时将自动创建该表。
- overwrite (bool) :如果为True,将覆盖表中现有的数据。
- is_external (bool) :如果为True,将表视为外部表。
- schema (可选,任意类型) :表的结构定义,可选参数。
返回值类型:None
write_parquet(target_name, database, create_if_not_exists=False, overwrite=False, is_external=False, schema=None)
描述:将数据写入指定的parquet表中。
输入参数:
- target_name (str) :目标表的名称。
- database (str) :表所属的数据库。
- create_if_not_exists (bool) :如果为True,当表不存在时将自动创建该表。
- overwrite (bool) :如果为True,将覆盖表中现有的数据。
- is_external (bool) :如果为True,将表视为外部表。
- schema(可选,任意类型):表的结构定义,可选参数。
返回值类型:None
父主题: 接口参考说明