func()

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
}