csv

Documentation

Index

• Constants
• Variables
• 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"

Variables

var FluxTestPackages = []*ast.Package{&ast.Package{
	BaseNode: ast.BaseNode{
		Comments: nil,
		Errors:   nil,
		Loc:      nil,
	},
	Files:   []*ast.File{},
	Package: "csv_test",
	Path:    "csv",
}}

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