File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -80,10 +80,15 @@ 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);
87+
8388 // Specifies types and object inspectors of columns to be scanned.
8489 val structOI = ObjectInspectorUtils
8590 .getStandardObjectInspector(
86- relation.tableDesc.getDeserializer .getObjectInspector,
91+ de .getObjectInspector,
8792 ObjectInspectorCopyOption .JAVA )
8893 .asInstanceOf [StructObjectInspector ]
8994
You can’t perform that action at this time.
0 commit comments