File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -188,7 +188,7 @@ class HadoopTableReader(
188
188
val hconf = broadcastedHiveConf.value.value
189
189
val deserializer = localDeserializer.newInstance()
190
190
deserializer.initialize(hconf, partProps)
191
- // get the table deserializer
191
+ // get the table deserializer
192
192
val tableSerDe = tableDesc.getDeserializerClass.newInstance()
193
193
tableSerDe.initialize(hconf, tableDesc.getProperties)
194
194
@@ -280,7 +280,7 @@ private[hive] object HadoopTableReader extends HiveInspectors {
280
280
281
281
val soi = convertdeserializer match {
282
282
case Some (convert) =>
283
- // check need to convert
283
+ // check need to convert
284
284
if (deserializer.getObjectInspector.equals(convert.getObjectInspector)) {
285
285
deserializer.getObjectInspector().asInstanceOf [StructObjectInspector ]
286
286
}
@@ -345,7 +345,7 @@ private[hive] object HadoopTableReader extends HiveInspectors {
345
345
if (deserializer.getObjectInspector.equals(convert.getObjectInspector)) {
346
346
deserializer.deserialize(value)
347
347
}
348
- // If partition schema does not match table schema, update the row to match
348
+ // If partition schema does not match table schema, update the row to match
349
349
else {
350
350
partTblObjectInspectorConverter.convert(deserializer.deserialize(value))
351
351
}
You can’t perform that action at this time.
0 commit comments