ADBC
Arrow 数据库连接
|
函数 | |
AdbcStatusCode | AdbcConnectionReadPartition (struct AdbcConnection *connection, const uint8_t *serialized_partition, size_t serialized_length, struct ArrowArrayStream *out, struct AdbcError *error) |
为查询的分区构造一个语句。然后可以独立读取结果。 | |
某些数据库可能会在内部对结果进行分区。这些分区会暴露给客户端,客户端可能希望将它们与线程或分布式执行模型集成,在这些模型中,分区可以在线程或机器之间划分以进行处理。
驱动程序不需要支持分区。
分区是无序的。如果结果集已排序,则实现应返回单个分区。
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 | 错误详细信息(如果发生错误)。 |