in client/sql/dataframereader.go [26:47]
func (w *dataFrameReaderImpl) Load(path string) (DataFrame, error) {
var format *string
if w.formatSource != "" {
format = &w.formatSource
}
df := &dataFrameImpl{
sparkSession: w.sparkSession,
relation: &proto.Relation{
RelType: &proto.Relation_Read{
Read: &proto.Read{
ReadType: &proto.Read_DataSource_{
DataSource: &proto.Read_DataSource{
Format: format,
Paths: []string{path},
},
},
},
},
},
}
return df, nil
}