更新时间: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

相关文档