Method findSchema

bq/provider.go:31–51

(typeName string)

}

func (p *typeProvider) findSchema(typeName string) (bigquery.Schema, bool) {
	typeNames := strings.Split(typeName, ".")
	schema, found := p.schemas[typeNames[0]]
	if !found {
		return nil, false
	}
	for _, tn := range typeNames[1:] {
		var s *bigquery.Schema
		for _, fieldSchema := range schema {
			if fieldSchema.Name == tn {
				s = &fieldSchema.Schema
				break
			}
		}
		if s == nil {
			return nil, false
		}
		schema = *s
	}
	return schema, true
}

func (p *typeProvider) FindType(typeName string) (*exprpb.Type, bool) {
	_, found := p.findSchema(typeName)