Documentation
¶
Index ¶
- func NewDataFrameRecordReader(df *dataframe.DataFrame) (array.RecordReader, error)
- type DataFrameRecordReader
- func (r *DataFrameRecordReader) Err() error
- func (r *DataFrameRecordReader) Next() bool
- func (r *DataFrameRecordReader) Record() arrow.Record
- func (r *DataFrameRecordReader) RecordBatch() arrow.RecordBatch
- func (r *DataFrameRecordReader) Release()
- func (r *DataFrameRecordReader) Retain()
- func (r *DataFrameRecordReader) Schema() *arrow.Schema
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDataFrameRecordReader ¶
func NewDataFrameRecordReader(df *dataframe.DataFrame) (array.RecordReader, error)
Types ¶
type DataFrameRecordReader ¶
type DataFrameRecordReader struct {
// contains filtered or unexported fields
}
func (*DataFrameRecordReader) Err ¶
func (r *DataFrameRecordReader) Err() error
func (*DataFrameRecordReader) Next ¶
func (r *DataFrameRecordReader) Next() bool
func (*DataFrameRecordReader) Record ¶
func (r *DataFrameRecordReader) Record() arrow.Record
func (*DataFrameRecordReader) RecordBatch ¶
func (r *DataFrameRecordReader) RecordBatch() arrow.RecordBatch
func (*DataFrameRecordReader) Release ¶
func (r *DataFrameRecordReader) Release()
func (*DataFrameRecordReader) Retain ¶
func (r *DataFrameRecordReader) Retain()
func (*DataFrameRecordReader) Schema ¶
func (r *DataFrameRecordReader) Schema() *arrow.Schema
Source Files
Click to show internal directories.
Click to hide internal directories.