common_reader

Documentation

Index

• func NewProjectionReader(reader array.RecordReader, options *options.ReadOptions, schema *arrow.Schema) array.RecordReader
• type DeleteReader
  • func NewDeleteReader(recordReader array.RecordReader, schemaOptions *schema.SchemaOptions, ...) *DeleteReader
  • func (d DeleteReader) Err() error
  • func (d DeleteReader) Next() bool
  • func (d DeleteReader) Record() arrow.Record
  • func (d DeleteReader) Release()
  • func (d DeleteReader) Retain()
  • func (d DeleteReader) Schema() *arrow.Schema
• type FilterReader
  • func MakeFilterReader(recordReader array.RecordReader, option *options.ReadOptions) *FilterReader
  • func (r *FilterReader) Err() error
  • func (r *FilterReader) Next() bool
  • func (r *FilterReader) Record() arrow.Record
  • func (r *FilterReader) Release()
  • func (r *FilterReader) Retain()
  • func (r *FilterReader) Schema() *arrow.Schema
• type ProjectionReader

Functions

func NewProjectionReader

func NewProjectionReader(reader array.RecordReader, options *options.ReadOptions, schema *arrow.Schema) array.RecordReader

Types

type DeleteReader

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

func NewDeleteReader

func NewDeleteReader(recordReader array.RecordReader, schemaOptions *schema.SchemaOptions, deleteFragments fragment.DeleteFragmentVector, options *options.ReadOptions) *DeleteReader

func (DeleteReader) Err

func (d DeleteReader) Err() error

func (DeleteReader) Next

func (d DeleteReader) Next() bool

func (DeleteReader) Record

func (d DeleteReader) Record() arrow.Record

func (DeleteReader) Release

func (d DeleteReader) Release()

func (DeleteReader) Retain

func (d DeleteReader) Retain()

func (DeleteReader) Schema

func (d DeleteReader) Schema() *arrow.Schema

type FilterReader

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

func MakeFilterReader

func MakeFilterReader(recordReader array.RecordReader, option *options.ReadOptions) *FilterReader

func (*FilterReader) Err

func (r *FilterReader) Err() error

func (*FilterReader) Next

func (r *FilterReader) Next() bool

func (*FilterReader) Record

func (r *FilterReader) Record() arrow.Record

func (*FilterReader) Release

func (r *FilterReader) Release()

func (*FilterReader) Retain

func (r *FilterReader) Retain()

func (*FilterReader) Schema

func (r *FilterReader) Schema() *arrow.Schema

type ProjectionReader

type ProjectionReader struct {
	array.RecordReader
	// contains filtered or unexported fields
}