func()

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
}