package csv

import "github.com/influxdata/flux/stdlib/csv"

Index ¶

• Constants
• func CreateSource(spec *FromCSVProcedureSpec, dsid execute.DatasetID, a execute.Administration) (execute.Source, error)
• type CSVSource
• func (c *CSVSource) AddTransformation(t execute.Transformation)
• func (c *CSVSource) Run(ctx context.Context)
• type FromCSVOpSpec
• func (s *FromCSVOpSpec) Kind() flux.OperationKind
• type FromCSVProcedureSpec
• func (s *FromCSVProcedureSpec) Copy() plan.ProcedureSpec
• func (s *FromCSVProcedureSpec) Kind() plan.ProcedureKind

Constants ¶

const FromCSVKind = "fromCSV"

Functions ¶

func CreateSource ¶

func CreateSource(spec *FromCSVProcedureSpec, dsid execute.DatasetID, a execute.Administration) (execute.Source, error)

Types ¶

type CSVSource ¶

type CSVSource struct {
	execute.ExecutionNode
	// contains filtered or unexported fields
}

func (*CSVSource) AddTransformation ¶

func (c *CSVSource) AddTransformation(t execute.Transformation)

func (*CSVSource) Run ¶

func (c *CSVSource) Run(ctx context.Context)

type FromCSVOpSpec ¶

type FromCSVOpSpec struct {
	CSV  string `json:"csv"`
	File string `json:"file"`
	Mode string `json:"mode"`
}

func (*FromCSVOpSpec) Kind ¶

func (s *FromCSVOpSpec) Kind() flux.OperationKind

type FromCSVProcedureSpec ¶

type FromCSVProcedureSpec struct {
	plan.DefaultCost
	CSV  string
	File string
	Mode string
}

func (*FromCSVProcedureSpec) Copy ¶

func (s *FromCSVProcedureSpec) Copy() plan.ProcedureSpec

func (*FromCSVProcedureSpec) Kind ¶

func (s *FromCSVProcedureSpec) Kind() plan.ProcedureKind

Source Files ¶

from.go