Skip to content

Commit 96e86aa

Browse files
Fix FakeV2Provider
1 parent ab66e58 commit 96e86aa

1 file changed

Lines changed: 2 additions & 6 deletions

File tree

sql/core/src/test/scala/org/apache/spark/sql/connector/FakeV2Provider.scala

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -108,10 +108,8 @@ class FakePathBasedSource
108108

109109
override def shortName(): String = "pathformat"
110110

111-
// Strip our own format prefix from the multipart path and return the rest under our
112-
// format-name namespace.
113111
override def extractIdentifier(options: CaseInsensitiveStringMap): Identifier =
114-
Identifier.of(Array(shortName()), options.get("path").stripPrefix(s"${shortName()}."))
112+
Identifier.of(Array(shortName()), options.get("path"))
115113
}
116114

117115
/**
@@ -131,8 +129,6 @@ class FakePathBasedSourceWithSessionConfig
131129

132130
override def extractCatalog(options: CaseInsensitiveStringMap): String = options.get("catalog")
133131

134-
// Strip our own format prefix from the multipart path and return the rest under our
135-
// format-name namespace.
136132
override def extractIdentifier(options: CaseInsensitiveStringMap): Identifier =
137-
Identifier.of(Array(shortName()), options.get("path").stripPrefix(s"${shortName()}."))
133+
Identifier.of(Array(shortName()), options.get("path"))
138134
}

0 commit comments

Comments
 (0)