in client/sql/dataframe.go [108:117]
func (df *dataFrameImpl) Schema() (*StructType, error) {
response, err := df.sparkSession.analyzePlan(df.createPlan())
if err != nil {
return nil, fmt.Errorf("failed to analyze plan: %w", err)
}
responseSchema := response.GetSchema().Schema
result := convertProtoDataTypeToStructType(responseSchema)
return result, nil
}