(sctx *super.Context, r io.Reader)
| 39 | } |
| 40 | |
| 41 | func NewReader(sctx *super.Context, r io.Reader) (*Reader, error) { |
| 42 | ipcReader, err := ipc.NewReader(r) |
| 43 | if err != nil { |
| 44 | return nil, err |
| 45 | } |
| 46 | ar, err := NewReaderFromRecordReader(sctx, ipcReader) |
| 47 | if err != nil { |
| 48 | ipcReader.Release() |
| 49 | return nil, err |
| 50 | } |
| 51 | return ar, nil |
| 52 | } |
| 53 | |
| 54 | func NewReaderFromRecordReader(sctx *super.Context, rbr RecordBatchReader) (*Reader, error) { |
| 55 | fields := rbr.Schema().Fields() |
no test coverage detected