Documentation ¶
Index ¶
- func ConvertToThriftReader(file ParquetFile, offset int64, size int64) *thrift.TBufferedTransport
- type BufferFile
- func (bf BufferFile) Bytes() []byte
- func (bf BufferFile) Close() error
- func (bf BufferFile) Create(name string) (ParquetFile, error)
- func (bf BufferFile) Open(name string) (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)
- type LocalFile
- func (self *LocalFile) Close() error
- func (self *LocalFile) Create(name string) (ParquetFile, error)
- func (self *LocalFile) Open(name string) (ParquetFile, error)
- func (self *LocalFile) Read(b []byte) (cnt int, err error)
- func (self *LocalFile) Seek(offset int64, pos int) (int64, error)
- func (self *LocalFile) Write(b []byte) (n int, err error)
- type ParquetFile
- type WriterFile
- func (self *WriterFile) Close() error
- func (self *WriterFile) Create(name string) (ParquetFile, error)
- func (self *WriterFile) Open(name string) (ParquetFile, error)
- func (self *WriterFile) Read(b []byte) (int, error)
- func (self *WriterFile) Seek(offset int64, pos int) (int64, error)
- func (self *WriterFile) Write(b []byte) (int, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertToThriftReader ¶
func ConvertToThriftReader(file ParquetFile, offset int64, size int64) *thrift.TBufferedTransport
Convert a file reater to Thrift reader
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) (ParquetFile, error)
func (BufferFile) Open ¶
func (bf BufferFile) Open(name string) (ParquetFile, error)
func (BufferFile) Read ¶
func (bf BufferFile) Read(p []byte) (cnt int, err error)
Read reads data form BufferFile into p.
type ParquetFile ¶
type ParquetFile interface { io.Seeker io.Reader io.Writer io.Closer Open(name string) (ParquetFile, error) Create(name string) (ParquetFile, error) }
func NewBufferFile ¶
func NewBufferFile(b []byte) (ParquetFile, error)
NewBufferFile creates new in memory parquet buffer.
func NewLocalFileReader ¶
func NewLocalFileReader(name string) (ParquetFile, error)
func NewLocalFileWriter ¶
func NewLocalFileWriter(name string) (ParquetFile, error)
func NewWriterFile ¶
func NewWriterFile(writer io.Writer) ParquetFile
type WriterFile ¶
func (*WriterFile) Close ¶
func (self *WriterFile) Close() error
func (*WriterFile) Create ¶
func (self *WriterFile) Create(name string) (ParquetFile, error)
func (*WriterFile) Open ¶
func (self *WriterFile) Open(name string) (ParquetFile, error)
Click to show internal directories.
Click to hide internal directories.