Partitioned Results

Collaboration diagram for Partitioned Results:

Functions
ADBC_EXPORT 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()

ADBC_EXPORT 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]	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.