arrowio

type Reader ¶

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

Reader is a zio.Reader for the Arrow IPC stream format.

func NewReader(zctx *zed.Context, r io.Reader) (*Reader, error)

func NewReaderFromRecordReader(zctx *zed.Context, rr pqarrow.RecordReader) (*Reader, error)

func (r *Reader) Close() error

func (r *Reader) Read() (*zed.Value, error)

type WriteCloser ¶ added in v1.8.0

type WriteCloser interface {
	Write(rec arrow.Record) error
	Close() error
}

type Writer ¶

type Writer struct {
	NewWriterFunc func(io.Writer, *arrow.Schema) (WriteCloser, error)
	// contains filtered or unexported fields
}

Writer is a zio.Writer for the Arrow IPC stream format. Given Zed values with appropriately named types (see the newArrowDataType implementation), it can write all Arrow types except dictionaries and sparse unions. (Although dictionaries are not part of the Zed data model, write support could be added using a named type.)

func NewWriter(w io.WriteCloser) *Writer

func (w *Writer) Close() error

func (w *Writer) Write(val zed.Value) error