File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -80,15 +80,14 @@ case class HiveTableScan(
8080 ColumnProjectionUtils .appendReadColumnIDs(hiveConf, neededColumnIDs)
8181 ColumnProjectionUtils .appendReadColumnNames(hiveConf, attributes.map(_.name))
8282
83- val td = relation.tableDesc
84- val deClass = td.getDeserializerClass;
85- val de = deClass.newInstance();
86- de.initialize(hiveConf, td.getProperties);
83+ val tableDesc = relation.tableDesc
84+ val deserializer = tableDesc.getDeserializerClass.newInstance
85+ deserializer.initialize(hiveConf, tableDesc.getProperties)
8786
8887 // Specifies types and object inspectors of columns to be scanned.
8988 val structOI = ObjectInspectorUtils
9089 .getStandardObjectInspector(
91- de .getObjectInspector,
90+ deserializer .getObjectInspector,
9291 ObjectInspectorCopyOption .JAVA )
9392 .asInstanceOf [StructObjectInspector ]
9493
You can’t perform that action at this time.
0 commit comments