Documentation
¶
Index ¶
- Constants
- type 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 ¶
View Source
const DefaultCapacity = 512
DefaultCapacity is the size in bytes of a new BufferFile's backing buffer
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) 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.
Click to show internal directories.
Click to hide internal directories.