csv

Documentation

Index

• Constants
• type CsvProcessor
  • func NewCsvProcessor() *CsvProcessor
  • func (p *CsvProcessor) GetRecord() (arrow.Record, error)
  • func (p *CsvProcessor) Init(params map[string]string, identifiers map[string]string, ...) error
  • func (p *CsvProcessor) OnData(data []byte) ([]byte, error)

Constants

const (
	CsvProcessorName string = "csv"
)

Types

type CsvProcessor

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

func NewCsvProcessor

func NewCsvProcessor() *CsvProcessor

func (*CsvProcessor) GetRecord

func (p *CsvProcessor) GetRecord() (arrow.Record, error)

func (*CsvProcessor) Init

func (p *CsvProcessor) Init(params map[string]string, identifiers map[string]string, measurements map[string]string, categories map[string]string, tags []string) error

func (*CsvProcessor) OnData

func (p *CsvProcessor) OnData(data []byte) ([]byte, error)