ADBC
Arrow Database Connectivity
|
Functions | |
AdbcStatusCode | AdbcConnectionReadPartition (struct AdbcConnection *connection, const uint8_t *serialized_partition, size_t serialized_length, struct ArrowArrayStream *out, struct AdbcError *error) |
Construct a statement for a partition of a query. The results can then be read independently. | |
Some databases may internally partition the results. These partitions are exposed to clients who may wish to integrate them with a threaded or distributed execution model, where partitions can be divided among threads or machines for processing.
Drivers are not required to support partitioning.
Partitions are not ordered. If the result set is sorted, implementations should return a single partition.
AdbcStatusCode AdbcConnectionReadPartition | ( | struct AdbcConnection * | connection, |
const uint8_t * | serialized_partition, | ||
size_t | serialized_length, | ||
struct ArrowArrayStream * | out, | ||
struct AdbcError * | error ) |
Construct a statement for a partition of a query. The results can then be read independently.
A partition can be retrieved from AdbcPartitions.
This AdbcConnection must outlive the returned ArrowArrayStream.
[in] | connection | The connection to use. This does not have to be the same connection that the partition was created on. |
[in] | serialized_partition | The partition descriptor. |
[in] | serialized_length | The partition descriptor length. |
[out] | out | The result set. |
[out] | error | Error details, if an error occurs. |