buffer

Documentation

Index

• func NewBufferFile(b []byte) (source.ParquetFile, error)
• type BufferFile
  • func (bf BufferFile) Bytes() []byte
  • func (bf BufferFile) Close() error
  • func (bf BufferFile) Create(name string) (source.ParquetFile, error)
  • func (bf BufferFile) Open(name string) (source.ParquetFile, error)
  • func (bf BufferFile) Read(p []byte) (cnt int, err error)
  • func (bf BufferFile) Seek(offset int64, pos int) (int64, error)
  • func (bf BufferFile) Write(p []byte) (int, error)

Functions

func NewBufferFile

func NewBufferFile(b []byte) (source.ParquetFile, error)

NewBufferFile creates new in memory parquet buffer.

Types

type BufferFile

type BufferFile struct {
	Reader *bytes.Reader
	Writer *bytes.Buffer
	// contains filtered or unexported fields
}

BufferFile allows reading parquet messages from a memory buffer.

func (BufferFile) Bytes

func (bf BufferFile) Bytes() []byte

func (BufferFile) Close

func (bf BufferFile) Close() error

Close is a no-op for a memory buffer.

func (BufferFile) Create

func (bf BufferFile) Create(name string) (source.ParquetFile, error)

func (BufferFile) Open

func (bf BufferFile) Open(name string) (source.ParquetFile, error)

func (BufferFile) Read

func (bf BufferFile) Read(p []byte) (cnt int, err error)

Read reads data form BufferFile into p.

func (BufferFile) Seek

func (bf BufferFile) Seek(offset int64, pos int) (int64, error)

Seek seeks in the underlying memory buffer.

func (BufferFile) Write

func (bf BufferFile) Write(p []byte) (int, error)

Write writes data from p into BufferFile.