Struct QdrantRecordBatchBuilder 

pub struct QdrantRecordBatchBuilder { /* private fields */ }

Schema-driven RecordBatch builder for Qdrant data.

This is the core component that converts Qdrant ScoredPoint data into Arrow RecordBatches for DataFusion consumption. It uses a clean, schema-driven architecture that eliminates the complex nested matching logic of previous implementations.

Architecture

The builder is initialized with an Arrow schema and creates one FieldExtractor per schema field in the exact same order. During processing, each point is processed once with all fields updated in a single pass, achieving O(F) performance where F is the number of fields.

Performance Features

• Single-Pass Processing: Each point is destructured once and all fields updated
• Owned Iteration: No unnecessary borrowing or reference management
• Pre-Allocated Builders: Capacity is allocated upfront for optimal memory usage
• Inline Logic: All processing logic is inline with no hidden function calls

Examples

use qdrant_datafusion::arrow::deserialize::QdrantRecordBatchBuilder;
use datafusion::arrow::datatypes::{Schema, Field, DataType};
use std::sync::Arc;

// Create schema and builder
let schema = Arc::new(Schema::new(vec![
    Field::new("id", DataType::Utf8, false),
    Field::new("vector", DataType::List(
        Arc::new(Field::new("item", DataType::Float32, true))
    ), true),
]));

let mut builder = QdrantRecordBatchBuilder::new(schema, 1000);

// Process points (would normally come from Qdrant query)
// for point in qdrant_points {
//     builder.append_point(point);
// }

// Create final record batch
// let batch = builder.finish()?;

Implementations

impl QdrantRecordBatchBuilder

pub fn new(schema: SchemaRef, point_count: usize) -> Self

Create builder from schema with proper capacity allocation

pub fn append_point(&mut self, point: ScoredPoint)

Append a point using owned destructuring - defines its own invariants

pub fn finish(self) -> DataFusionResult<RecordBatch>

Finish building and create the final RecordBatch

Errors

• Returns an error if RecordBatch creation fails.