buffer

Documentation

Index

• Constants
• type BufferFile
  • func NewBufferFile() *BufferFile
  • func NewBufferFileCapacity(cap int) *BufferFile
  • func NewBufferFileFromBytes(s []byte) *BufferFile
  • func (bf BufferFile) Bytes() []byte
  • func (bf BufferFile) Close() error
  • func (bf BufferFile) Create(string) (source.ParquetFile, error)
  • func (bf BufferFile) Open(string) (source.ParquetFile, error)
  • func (bf *BufferFile) Read(p []byte) (n int, err error)
  • func (bf *BufferFile) Seek(offset int64, whence int) (int64, error)
  • func (bf *BufferFile) Write(p []byte) (n int, err error)

Constants

const DefaultCapacity = 512

DefaultCapacity is the size in bytes of a new BufferFile's backing buffer

Types

type BufferFile

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

BufferFile allows reading parquet messages from a memory buffer.

func NewBufferFile

func NewBufferFile() *BufferFile

NewBufferFile creates new in memory parquet buffer.

func NewBufferFileCapacity

func NewBufferFileCapacity(cap int) *BufferFile

NewBufferFileCapacity starts the returned BufferFile with the given capacity

func NewBufferFileFromBytes

func NewBufferFileFromBytes(s []byte) *BufferFile

NewBufferFileFromBytes creates new in memory parquet buffer from the given bytes.

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(string) (source.ParquetFile, error)

func (BufferFile) Open

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

func (*BufferFile) Read

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

Read reads data form BufferFile into p.

func (*BufferFile) Seek

func (bf *BufferFile) Seek(offset int64, whence int) (int64, error)

Seek seeks in the underlying memory buffer.

func (*BufferFile) Write

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

Write writes data from p into BufferFile.