writer

Documentation

Index

• type CsvWriter
  • func NewCswGzWriter(path string, entity interface{}) (*CsvWriter, error)
  • func NewCswWriter(path string, entity interface{}) (*CsvWriter, error)
  • func (writer *CsvWriter) Close() error
  • func (writer *CsvWriter) Write(data interface{}) error
• type ParquetWriter
  • func NewParquetWriter(path string, obj interface{}) (*ParquetWriter, error)
  • func (pw *ParquetWriter) Close() error
  • func (pw *ParquetWriter) Write(data interface{}) error
• type Test2
• type Writer
  • func NewWriter(name string, format string, entitiy interface{}) (Writer, error)

Types

type CsvWriter

type CsvWriter struct {
	// contains filtered or unexported fields
}

func NewCswGzWriter

func NewCswGzWriter(path string, entity interface{}) (*CsvWriter, error)

func NewCswWriter

func NewCswWriter(path string, entity interface{}) (*CsvWriter, error)

func (*CsvWriter) Close

func (writer *CsvWriter) Close() error

func (*CsvWriter) Write

func (writer *CsvWriter) Write(data interface{}) error

type ParquetWriter

type ParquetWriter struct {
	// contains filtered or unexported fields
}

func NewParquetWriter

func NewParquetWriter(path string, obj interface{}) (*ParquetWriter, error)

func (*ParquetWriter) Close

func (pw *ParquetWriter) Close() error

func (*ParquetWriter) Write

func (pw *ParquetWriter) Write(data interface{}) error

type Test2

type Test2 struct {
	Name  string `parquet:"name=name, type=UTF8, encoding=PLAIN_DICTIONARY"`
	Value int32  `parquet:"name=age, type=INT32, encoding=PLAIN"`
}

type Writer

type Writer interface {
	Write(data interface{}) error
	Close() error
}

func NewWriter

func NewWriter(name string, format string, entitiy interface{}) (Writer, error)