Struct XmlReader 

pub struct XmlReader<'a> { /* private fields */ }

Reads XML records selected by an absolute path into Arrow batches.

Implementations

impl<'a> XmlReader<'a>

pub fn new<R: AsyncBufRead + Unpin + Send + 'a>( input: R, schema: XmlSchema, record_path: &str, options: ReaderOptions, ) -> Result<Self>

Creates a reader without reading input. Path prefixes use schema bindings.

pub async fn infer<R: AsyncBufRead + Unpin + Send + 'a>( input: R, record_path: &str, bindings: &[NamespaceBinding<'_>], options: ReaderOptions, sampling: InferenceOptions, ) -> Result<Self>

Infers a fixed schema from a bounded sample, then replays sampled records. Bindings resolve record-path prefixes; other namespaces get generated prefixes.

pub fn schema(&self) -> SchemaRef

Projected output schema.

pub async fn next_batch(&mut self) -> Result<Option<RecordBatch>>

Returns a batch or EOF. The first error discards pending rows and ends input. Cancelled calls can resume; calls after an error return None.

pub fn into_stream(self) -> BoxStream<'a, Result<RecordBatch>>

Consumes the reader as a batch stream.