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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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) 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.
Click to show internal directories.
Click to hide internal directories.