Method load

plan/plan.go:751–789

()

	return nil
}
func (m *Source) load() error {
	// u.Debugf("source load schema=%s from=%s  %#v", m.ctx.Schema.Name, m.Stmt.SourceName(), m.Stmt)
	if m.Stmt == nil {
		return nil
	}
	fromName := strings.ToLower(m.Stmt.SourceName())
	if m.ctx == nil {
		return fmt.Errorf("missing context in Source")
	}
	if m.ctx.Schema == nil {
		u.Errorf("missing schema in *plan.Source load() from:%q", fromName)
		return fmt.Errorf("Missing schema for %v", fromName)
	}

	ss, err := m.ctx.Schema.SchemaForTable(fromName)
	if err != nil {
		// u.Debugf("no schema found for %T  %q.%q ? err=%v", m.ctx.Schema, m.Stmt.Schema, fromName, err)
		return nil
	}
	if ss == nil {
		u.Warnf("%p Schema  no %s found", m.ctx.Schema, fromName)
		return fmt.Errorf("Could not find source for %v", m.Stmt.SourceName())
	}
	m.Schema = ss
	// Create a context-datasource
	m.DataSource = ss.DS

	tbl, err := m.ctx.Schema.Table(fromName)
	if err != nil {
		return err
	}
	if tbl == nil {
		return fmt.Errorf("No table found for %q", fromName)
	}
	m.Tbl = tbl

	//u.Infof("schema=%s ds:%T  tbl:%v", m.Schema.Name, m.DataSource, tbl)
	return projectionForSourcePlan(m)
}

// Equal checks if two tasks are equal.
func (m *Projection) Equal(t Task) bool {