mac-zhenfang opened a new issue, #43443:
URL: https://github.com/apache/arrow/issues/43443
### Describe the usage question you have. Please include as many useful
details as possible.
The func NewRecordWriter(w DataStreamWriter, opts ...ipc.Option) *Writer
API indicates the DataStreamWriter is a required parameter, all the others are
optional. But in the
func (w *Writer) start() error {
w.started = true
w.mapper.ImportSchema(w.schema)
w.lastWrittenDicts = make(map[int64]arrow.Array)
// write out schema payloads
ps := payloadFromSchema(w.schema, w.mem, &w.mapper)
defer ps.Release()
for _, data := range ps {
err := w.pw.WritePayload(data)
if err != nil {
return err
}
}
return nil
}
The w.schema looks a required parameter. If it s nil, will report arrow/ipc:
unknown error while writing: runtime error: invalid memory address or nil
pointer dereference error.
The request is to use the Schema in RecordBatch, instead of a input option
### Component(s)
Go
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
