in client/sql/sparksession.go [53:77]
func (s SparkSessionBuilder) Build() (sparkSession, error) {
cb, err := channel.NewBuilder(s.connectionString)
if err != nil {
return nil, fmt.Errorf("failed to connect to remote %s: %w", s.connectionString, err)
}
conn, err := cb.Build()
if err != nil {
return nil, fmt.Errorf("failed to connect to remote %s: %w", s.connectionString, err)
}
// Add metadata to the request.
meta := metadata.MD{}
for k, v := range cb.Headers {
meta[k] = append(meta[k], v)
}
client := proto.NewSparkConnectServiceClient(conn)
return &sparkSessionImpl{
sessionId: uuid.NewString(),
client: client,
metadata: meta,
}, nil
}