ADBC
Arrow Database Connectivity
Loading...
Searching...
No Matches
Partitioned Results

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.
 

Detailed Description

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.

Function Documentation

◆ AdbcConnectionReadPartition()

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.

Parameters
[in]connectionThe connection to use. This does not have to be the same connection that the partition was created on.
[in]serialized_partitionThe partition descriptor.
[in]serialized_lengthThe partition descriptor length.
[out]outThe result set.
[out]errorError details, if an error occurs.