File tree Expand file tree Collapse file tree 1 file changed +2
-9
lines changed
sql/core/src/main/scala/org/apache/spark/sql/sources Expand file tree Collapse file tree 1 file changed +2
-9
lines changed Original file line number Diff line number Diff line change @@ -121,7 +121,7 @@ private[sql] class DDLParser extends StandardTokenParsers with PackratParsers wi
121
121
122
122
protected lazy val column : Parser [StructField ] =
123
123
ident ~ dataType ^^ { case columnName ~ typ =>
124
- StructField (cleanIdentifier( columnName) , typ)
124
+ StructField (columnName, typ)
125
125
}
126
126
127
127
protected lazy val primitiveType : Parser [DataType ] =
@@ -157,7 +157,7 @@ private[sql] class DDLParser extends StandardTokenParsers with PackratParsers wi
157
157
158
158
protected lazy val structField : Parser [StructField ] =
159
159
ident ~ " :" ~ dataType ^^ {
160
- case fieldName ~ _ ~ tpe => StructField (cleanIdentifier( fieldName) , tpe, nullable = true )
160
+ case fieldName ~ _ ~ tpe => StructField (fieldName, tpe, nullable = true )
161
161
}
162
162
163
163
protected lazy val structType : Parser [DataType ] =
@@ -173,13 +173,6 @@ private[sql] class DDLParser extends StandardTokenParsers with PackratParsers wi
173
173
mapType |
174
174
structType |
175
175
primitiveType
176
-
177
- protected val escapedIdentifier = " `([^`]+)`" .r
178
- /** Strips backticks from ident if present */
179
- protected def cleanIdentifier (ident : String ): String = ident match {
180
- case escapedIdentifier(i) => i
181
- case plainIdent => plainIdent
182
- }
183
176
}
184
177
185
178
private [sql] case class CreateTableUsing (
You can’t perform that action at this time.
0 commit comments