Method Read

sio/arrowio/reader.go:96–127

()

}

func (r *Reader) Read() (*super.Value, error) {
	for r.batch == nil {
		batch, err := r.rbr.Read()
		if err != nil {
			if err == io.EOF {
				return nil, nil
			}
			return nil, err
		}
		if batch.NumRows() > 0 {
			r.batch = batch
			r.i = 0
		} else {
			batch.Release()
		}
	}
	r.builder.Truncate()
	for j, array := range r.batch.Columns() {
		typ := r.topLevelType.Fields[j].Type
		nullable := r.topLevelFields[j].Nullable
		if err := r.buildScodeWithNullable(typ, array, r.i, nullable); err != nil {
			return nil, err
		}
	}
	r.val = super.NewValue(r.topLevelType, r.builder.Bytes())
	r.i++
	if r.i >= int(r.batch.NumRows()) {
		r.batch.Release()
		r.batch = nil
	}
	return &r.val, nil
}

var dayTimeIntervalFields = []super.Field{
	{Name: "days", Type: super.TypeInt32},