ADBC
Arrow 数据库连接
加载中...
搜索中...
无匹配项
分区结果

函数

AdbcStatusCode AdbcConnectionReadPartition (struct AdbcConnection *connection, const uint8_t *serialized_partition, size_t serialized_length, struct ArrowArrayStream *out, struct AdbcError *error)
 为查询的分区构造一个语句。然后可以独立读取结果。
 

详细描述

某些数据库可能会在内部对结果进行分区。这些分区会暴露给客户端,客户端可能希望将它们与线程或分布式执行模型集成,在这些模型中,分区可以在线程或机器之间划分以进行处理。

驱动程序不需要支持分区。

分区是无序的。如果结果集已排序,则实现应返回单个分区。

函数文档

◆ AdbcConnectionReadPartition()

AdbcStatusCode AdbcConnectionReadPartition ( struct AdbcConnection * connection,
const uint8_t * serialized_partition,
size_t serialized_length,
struct ArrowArrayStream * out,
struct AdbcError * error )

为查询的分区构造一个语句。然后可以独立读取结果。

可以从 AdbcPartitions 中检索分区。

AdbcConnection 的生命周期必须超过返回的 ArrowArrayStream。

参数
[输入]connection要使用的连接。这不必与创建分区时使用的连接相同。
[输入]serialized_partition分区描述符。
[输入]serialized_length分区描述符长度。
[输出]out结果集。
[输出]error错误详细信息(如果发生错误)。