pipelines

Documentation

Index

• type ConvertSQLJoint
  • func (joint ConvertSQLJoint) Name() string
  • func (joint ConvertSQLJoint) Process(c *pipeline.Context) error
• type DetectMaxIDJoint
  • func (joint DetectMaxIDJoint) Name() string
  • func (joint DetectMaxIDJoint) Process(c *pipeline.Context) error
• type ImportSQLJoint
  • func (joint ImportSQLJoint) Name() string
  • func (joint ImportSQLJoint) Process(c *pipeline.Context) error
• type LoggingJoint
  • func (joint LoggingJoint) Name() string
  • func (joint LoggingJoint) Process(c *pipeline.Context) error
• type ReadCsvJoint
  • func (joint ReadCsvJoint) Name() string
  • func (joint ReadCsvJoint) Process(c *pipeline.Context) error
• type RowStructureJoint
  • func (joint RowStructureJoint) Name() string
  • func (joint RowStructureJoint) Process(c *pipeline.Context) error

Types

type ConvertSQLJoint

type ConvertSQLJoint struct {
	pipeline.Parameters
}

func (ConvertSQLJoint) Name

func (joint ConvertSQLJoint) Name() string

func (ConvertSQLJoint) Process

func (joint ConvertSQLJoint) Process(c *pipeline.Context) error

type DetectMaxIDJoint

type DetectMaxIDJoint struct {
}

func (DetectMaxIDJoint) Name

func (joint DetectMaxIDJoint) Name() string

func (DetectMaxIDJoint) Process

func (joint DetectMaxIDJoint) Process(c *pipeline.Context) error

type ImportSQLJoint

type ImportSQLJoint struct {
	pipeline.Parameters
}

func (ImportSQLJoint) Name

func (joint ImportSQLJoint) Name() string

func (ImportSQLJoint) Process

func (joint ImportSQLJoint) Process(c *pipeline.Context) error

type LoggingJoint

type LoggingJoint struct {
}

func (LoggingJoint) Name

func (joint LoggingJoint) Name() string

func (LoggingJoint) Process

func (joint LoggingJoint) Process(c *pipeline.Context) error

type ReadCsvJoint

type ReadCsvJoint struct {
	pipeline.Parameters
}

func (ReadCsvJoint) Name

func (joint ReadCsvJoint) Name() string

func (ReadCsvJoint) Process

func (joint ReadCsvJoint) Process(c *pipeline.Context) error

type RowStructureJoint

type RowStructureJoint struct {
}

func (RowStructureJoint) Name

func (joint RowStructureJoint) Name() string

func (RowStructureJoint) Process

func (joint RowStructureJoint) Process(c *pipeline.Context) error