inmemory

Documentation

Index

• func NewInMemoryFileReader(name string) (source.ParquetFile, error)
• func NewInMemoryFileWriter(name string) (source.ParquetFile, error)
• func Remove(path string) error
• func RemoveAll(path string) error
• type InMemoryFile
  • func (self *InMemoryFile) Close() error
  • func (self *InMemoryFile) Create(name string) (source.ParquetFile, error)
  • func (self *InMemoryFile) Open(name string) (source.ParquetFile, error)
  • func (self *InMemoryFile) Read(b []byte) (cnt int, err error)
  • func (self *InMemoryFile) Seek(offset int64, pos int) (int64, error)
  • func (self *InMemoryFile) Write(b []byte) (n int, err error)

Functions

func NewInMemoryFileReader

func NewInMemoryFileReader(name string) (source.ParquetFile, error)

func NewInMemoryFileWriter

func NewInMemoryFileWriter(name string) (source.ParquetFile, error)

func Remove

func Remove(path string) error

func RemoveAll

func RemoveAll(path string) error

Types

type InMemoryFile

type InMemoryFile struct {
	FilePath string
	File     afero.File
}

func (*InMemoryFile) Close

func (self *InMemoryFile) Close() error

func (*InMemoryFile) Create

func (self *InMemoryFile) Create(name string) (source.ParquetFile, error)

func (*InMemoryFile) Open

func (self *InMemoryFile) Open(name string) (source.ParquetFile, error)

func (*InMemoryFile) Read

func (self *InMemoryFile) Read(b []byte) (cnt int, err error)

func (*InMemoryFile) Seek

func (self *InMemoryFile) Seek(offset int64, pos int) (int64, error)

func (*InMemoryFile) Write

func (self *InMemoryFile) Write(b []byte) (n int, err error)