Versions in this module Expand all Collapse all v0 v0.0.1 Dec 1, 2023 Changes in this version + func NewHdfsFileReader(hosts []string, user string, name string) (source.ParquetFile, error) + func NewHdfsFileWriter(hosts []string, user string, name string) (source.ParquetFile, error) + type HdfsFile struct + Client *hdfs.Client + FilePath string + FileReader *hdfs.FileReader + FileWriter *hdfs.FileWriter + Hosts []string + User string + func (self *HdfsFile) Close() error + func (self *HdfsFile) Create(name string) (source.ParquetFile, error) + func (self *HdfsFile) Open(name string) (source.ParquetFile, error) + func (self *HdfsFile) Read(b []byte) (cnt int, err error) + func (self *HdfsFile) Seek(offset int64, pos int) (int64, error) + func (self *HdfsFile) Write(b []byte) (n int, err error)
Go to main page