Skip to content

Commit 7520f7f

Browse files
committed
MapR [SPARK-904] Implement inferSchema method for MaprDBDataSource (apache#847)
Co-authored-by: Egor Krivokon <>
1 parent 61d26ca commit 7520f7f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

external/maprdb/src/main/scala/com/mapr/db/spark/sql/v2/MapRDBDataSource.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,8 @@ class MapRDBDataSource
3232
* e.g. file path, Kafka topic name, etc.
3333
*/
3434
override def inferSchema(options: CaseInsensitiveStringMap): StructType = {
35-
// getTable(null, Array.empty[Transform], options.asCaseSensitiveMap()).schema()
36-
// TODO: Implement me
35+
// MaprDb connector for DataSourceV2 doesn't support loadFromMaprDB method without schema specifying,
36+
// so schema needs to be specified by user
3737
null
3838
}
3939

0 commit comments

Comments
 (0)