myarrow

Documentation

Index

• func ToArrowSchema(s sql.Schema, dictionary ...int) (*arrow.Schema, error)
• func ToArrowType(t sql.Type) (arrow.DataType, error)
• type ArrowAppender
  • func NewArrowAppender(schema sql.Schema, dictionary ...int) (ArrowAppender, error)
  • func (a *ArrowAppender) Append(row sql.Row) error
  • func (a *ArrowAppender) Build() arrow.Record
  • func (a *ArrowAppender) Grow(n int)

Functions

func ToArrowSchema

func ToArrowSchema(s sql.Schema, dictionary ...int) (*arrow.Schema, error)

func ToArrowType

func ToArrowType(t sql.Type) (arrow.DataType, error)

ToArrowType translates the MySQL Type to Arrow Type.

Types

type ArrowAppender

type ArrowAppender struct {
	*array.RecordBuilder
}

func NewArrowAppender

func NewArrowAppender(schema sql.Schema, dictionary ...int) (ArrowAppender, error)

func (*ArrowAppender) Append

func (a *ArrowAppender) Append(row sql.Row) error

func (*ArrowAppender) Build

func (a *ArrowAppender) Build() arrow.Record

Build creates a new arrow.Record from the memory buffers and resets the builder. The returned Record must be Release()'d after use.

func (*ArrowAppender) Grow

func (a *ArrowAppender) Grow(n int)

Grow increases the capacity of the builder to at least n rows. This method is intended to be used to preallocate memory for the builder after Build() has been called.