parquet

Documentation

Index

• type FileReader
  • func NewFileReader(fs fs.Fs, filePath string, options *options.ReadOptions) (*FileReader, error)
  • func (r *FileReader) Close() error
  • func (r *FileReader) Read() (arrow.Record, error)
• type FileWriter
  • func NewFileWriter(schema *arrow.Schema, fs fs.Fs, filePath string) (*FileWriter, error)
  • func (f *FileWriter) Close() error
  • func (f *FileWriter) Count() int64
  • func (f *FileWriter) Write(record arrow.Record) error

Types

type FileReader

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

func NewFileReader

func NewFileReader(fs fs.Fs, filePath string, options *options.ReadOptions) (*FileReader, error)

func (*FileReader) Close

func (r *FileReader) Close() error

func (*FileReader) Read

func (r *FileReader) Read() (arrow.Record, error)

When the Reader reaches the end of the underlying stream, it returns (nil, io.EOF)

type FileWriter

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

func NewFileWriter

func NewFileWriter(schema *arrow.Schema, fs fs.Fs, filePath string) (*FileWriter, error)

func (*FileWriter) Close

func (f *FileWriter) Close() error

func (*FileWriter) Count

func (f *FileWriter) Count() int64

func (*FileWriter) Write

func (f *FileWriter) Write(record arrow.Record) error