csvreader

Documentation

Index

• func ColumnSeriesMapFromCSVData(csmInit ColumnSeriesMap, key TimeBucketKey, csvRows [][]string, ...) (csm ColumnSeriesMap)
• func GetFloat32ColumnFromCSVRows(csvRows [][]string, index int) (col []float32, err error)
• func GetFloat64ColumnFromCSVRows(csvRows [][]string, index int) (col []float64, err error)
• func GetInt32ColumnFromCSVRows(csvRows [][]string, index int) (col []int32, err error)
• func GetInt64ColumnFromCSVRows(csvRows [][]string, index int) (col []int64, err error)
• func TimeColumnsFromCSV(csvData [][]string, columnIndex []int, conf *Configuration) (epochCol []int64, nanosCol []int32)
• type Configuration
  • func NewConfiguration() *Configuration
  • func ReadCSVFileMetadata(dataFD, controlFD *os.File, dataShapes []DataShape) (columnIndex []int, csvReader *csv.Reader, conf *Configuration, err error)

Functions

func ColumnSeriesMapFromCSVData

func ColumnSeriesMapFromCSVData(csmInit ColumnSeriesMap, key TimeBucketKey, csvRows [][]string, columnIndex []int,
	dataShapes []DataShape) (csm ColumnSeriesMap)

func GetFloat32ColumnFromCSVRows

func GetFloat32ColumnFromCSVRows(csvRows [][]string, index int) (col []float32, err error)

func GetFloat64ColumnFromCSVRows

func GetFloat64ColumnFromCSVRows(csvRows [][]string, index int) (col []float64, err error)

func GetInt32ColumnFromCSVRows

func GetInt32ColumnFromCSVRows(csvRows [][]string, index int) (col []int32, err error)

func GetInt64ColumnFromCSVRows

func GetInt64ColumnFromCSVRows(csvRows [][]string, index int) (col []int64, err error)

func TimeColumnsFromCSV

func TimeColumnsFromCSV(csvData [][]string, columnIndex []int, conf *Configuration) (epochCol []int64, nanosCol []int32)

Types

type Configuration

type Configuration struct {
	FirstRowHasColumnNames bool     `yaml:"firstRowHasColumnNames"`
	TimeFormat             string   `yaml:"timeFormat"`
	Timezone               string   `yaml:"timeZone"`
	ColumnNameMap          []string `yaml:"columnNameMap"`
}

func NewConfiguration

func NewConfiguration() *Configuration

func ReadCSVFileMetadata

func ReadCSVFileMetadata(dataFD, controlFD *os.File, dataShapes []DataShape) (columnIndex []int, csvReader *csv.Reader, conf *Configuration, err error)