record_reader

Documentation

Index

• func MakeRecordReader(m *manifest.Manifest, s *schema.Schema, f fs.Fs, ...) array.RecordReader
• func MakeScanDeleteReader(manifest *manifest.Manifest, fs fs.Fs) array.RecordReader
• func NewFilterQueryReader(s *schema.Schema, options *options.ReadOptions, f fs.Fs, ...) array.RecordReader
• type FilterQueryRecordReader
• type MergeRecordReader
  • func NewMergeRecordReader(s *schema.Schema, options *options.ReadOptions, f fs.Fs, ...) *MergeRecordReader
  • func (m MergeRecordReader) Err() error
  • func (m MergeRecordReader) Next() bool
  • func (m MergeRecordReader) Record() arrow.Record
  • func (m MergeRecordReader) Release()
  • func (m MergeRecordReader) Retain()
  • func (m MergeRecordReader) Schema() *arrow.Schema
• type MultiFilesSequentialReader
  • func NewMultiFilesSequentialReader(fs fs.Fs, fragments fragment.FragmentVector, schema *arrow.Schema, ...) *MultiFilesSequentialReader
  • func (m *MultiFilesSequentialReader) Err() error
  • func (m *MultiFilesSequentialReader) Next() bool
  • func (m *MultiFilesSequentialReader) Record() arrow.Record
  • func (m *MultiFilesSequentialReader) Release()
  • func (m *MultiFilesSequentialReader) Retain()
  • func (m *MultiFilesSequentialReader) Schema() *arrow.Schema
• type ScanRecordReader
  • func NewScanRecordReader(s *schema.Schema, options *options.ReadOptions, f fs.Fs, ...) *ScanRecordReader
  • func (r *ScanRecordReader) Err() error
  • func (r *ScanRecordReader) MakeInnerReader() array.RecordReader
  • func (r *ScanRecordReader) Next() bool
  • func (r *ScanRecordReader) Record() arrow.Record
  • func (r *ScanRecordReader) Release()
  • func (r *ScanRecordReader) Retain()
  • func (r *ScanRecordReader) Schema() *arrow.Schema

Functions

func MakeRecordReader

func MakeRecordReader(
	m *manifest.Manifest,
	s *schema.Schema,
	f fs.Fs,
	deleteFragments fragment.DeleteFragmentVector,
	options *options.ReadOptions,
) array.RecordReader

func MakeScanDeleteReader

func MakeScanDeleteReader(manifest *manifest.Manifest, fs fs.Fs) array.RecordReader

func NewFilterQueryReader

func NewFilterQueryReader(
	s *schema.Schema,
	options *options.ReadOptions,
	f fs.Fs,
	scalarFragment fragment.FragmentVector,
	vectorFragment fragment.FragmentVector,
	deleteFragments fragment.DeleteFragmentVector) array.RecordReader

Types

type FilterQueryRecordReader

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

type MergeRecordReader

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

func NewMergeRecordReader

func NewMergeRecordReader(
	s *schema.Schema,
	options *options.ReadOptions,
	f fs.Fs,
	scalarFragment fragment.FragmentVector,
	vectorFragment fragment.FragmentVector,
	deleteFragments fragment.DeleteFragmentVector) *MergeRecordReader

func (MergeRecordReader) Err

func (m MergeRecordReader) Err() error

func (MergeRecordReader) Next

func (m MergeRecordReader) Next() bool

func (MergeRecordReader) Record

func (m MergeRecordReader) Record() arrow.Record

func (MergeRecordReader) Release

func (m MergeRecordReader) Release()

func (MergeRecordReader) Retain

func (m MergeRecordReader) Retain()

func (MergeRecordReader) Schema

func (m MergeRecordReader) Schema() *arrow.Schema

type MultiFilesSequentialReader

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

func NewMultiFilesSequentialReader

func NewMultiFilesSequentialReader(fs fs.Fs, fragments fragment.FragmentVector, schema *arrow.Schema, options *options.ReadOptions) *MultiFilesSequentialReader

func (*MultiFilesSequentialReader) Err

func (m *MultiFilesSequentialReader) Err() error

func (*MultiFilesSequentialReader) Next

func (m *MultiFilesSequentialReader) Next() bool

func (*MultiFilesSequentialReader) Record

func (m *MultiFilesSequentialReader) Record() arrow.Record

func (*MultiFilesSequentialReader) Release

func (m *MultiFilesSequentialReader) Release()

func (*MultiFilesSequentialReader) Retain

func (m *MultiFilesSequentialReader) Retain()

func (*MultiFilesSequentialReader) Schema

func (m *MultiFilesSequentialReader) Schema() *arrow.Schema

type ScanRecordReader

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

func NewScanRecordReader

func NewScanRecordReader(
	s *schema.Schema,
	options *options.ReadOptions,
	f fs.Fs,
	dataFragments fragment.FragmentVector,
	deleteFragments fragment.DeleteFragmentVector,
) *ScanRecordReader

func (*ScanRecordReader) Err

func (r *ScanRecordReader) Err() error

func (*ScanRecordReader) MakeInnerReader

func (r *ScanRecordReader) MakeInnerReader() array.RecordReader

func (*ScanRecordReader) Next

func (r *ScanRecordReader) Next() bool

func (*ScanRecordReader) Record

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

func (*ScanRecordReader) Release

func (r *ScanRecordReader) Release()

func (*ScanRecordReader) Retain

func (r *ScanRecordReader) Retain()

func (*ScanRecordReader) Schema

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