flatten

package

v0.2.0 Latest Latest Go to latest Published: Mar 19, 2026 License: MIT Imports: 5 Imported by: 0

Details

Package flatten provides a RecordReader wrapper that flattens complex Arrow types (Struct, List, Map, Union) to simple columns.

This section is empty.

This section is empty.

This section is empty.

type Converter struct {
	// contains filtered or unexported fields
}

Converter wraps an array.RecordReader and flattens complex types. Implements array.RecordReader.

func NewConverter(source array.RecordReader) *Converter

NewConverter creates a flattening RecordReader wrapper. If the schema has no complex types, batches pass through unchanged.

func (c *Converter) Err() error

func (c *Converter) Next() bool

func (c *Converter) Record() arrow.RecordBatch

func (c *Converter) RecordBatch() arrow.RecordBatch

func (c *Converter) Release()

func (c *Converter) Retain()

func (c *Converter) Schema() *arrow.Schema