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 存在的时间更长。

参数
[in]connection要使用的连接。 这不必是创建分区的同一连接。
[in]serialized_partition分区描述符。
[in]serialized_length分区描述符长度。
[out]out结果集。
[out]error如果发生错误,则为错误详细信息。