SPARK-3807: SparkSql does not work for tables created using custom se…

…rde (Incorporated Review Comments)
jkbradley · Oct 10, 2014 · 1f26805 · 1f26805
1 parent ba4bc0c
commit 1f26805
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveTableScan.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveTableScan.scala
@@ -80,15 +80,14 @@ case class HiveTableScan(
     ColumnProjectionUtils.appendReadColumnIDs(hiveConf, neededColumnIDs)
     ColumnProjectionUtils.appendReadColumnNames(hiveConf, attributes.map(_.name))
 
-    val td = relation.tableDesc
-    val deClass = td.getDeserializerClass;
-    val de = deClass.newInstance();
-    de.initialize(hiveConf, td.getProperties);
+    val tableDesc = relation.tableDesc
+    val deserializer = tableDesc.getDeserializerClass.newInstance
+    deserializer.initialize(hiveConf, tableDesc.getProperties)
 
     // Specifies types and object inspectors of columns to be scanned.
     val structOI = ObjectInspectorUtils
       .getStandardObjectInspector(
-        de.getObjectInspector,
+        deserializer.getObjectInspector,
         ObjectInspectorCopyOption.JAVA)
       .asInstanceOf[StructObjectInspector]