Documentation ¶
Index ¶
- func ConvertToThriftReader(file ParquetFile, offset int64, size int64) *thrift.TBufferedTransport
- 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 ParquetFile ¶
type ParquetFile interface { io.Seeker io.Reader io.Writer io.Closer Open(name string) (ParquetFile, error) Create(name string) (ParquetFile, error) }
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.