Function NewSourceScanner

exec/source.go:87–94

NewSourceScanner A scanner to read from sub-query data source (join, sub-query, static)

(ctx *plan.Context, p *plan.Source, scanner schema.ConnScanner)

// NewSourceScanner A scanner to read from sub-query data source (join, sub-query, static)
func NewSourceScanner(ctx *plan.Context, p *plan.Source, scanner schema.ConnScanner) *Source {
	s := &Source{
		TaskBase: NewTaskBase(ctx),
		Scanner:  scanner,
		p:        p,
	}
	return s
}

func (m *Source) Copy() *Source { return &Source{} }