in spark/sql/column/expressions.go [220:243]
func (u *unresolvedFunction) ToProto(ctx context.Context) (*proto.Expression, error) {
// Convert input args to the proto expression.
var args []*proto.Expression = nil
if len(u.args) > 0 {
args = make([]*proto.Expression, 0)
for _, arg := range u.args {
p, e := arg.ToProto(ctx)
if e != nil {
return nil, e
}
args = append(args, p)
}
}
expr := newProtoExpression()
expr.ExprType = &proto.Expression_UnresolvedFunction_{
UnresolvedFunction: &proto.Expression_UnresolvedFunction{
FunctionName: u.name,
Arguments: args,
IsDistinct: u.isDistinct,
},
}
return expr, nil
}