From 10744cac4cc014216241fc97c6495924cc51fdbc Mon Sep 17 00:00:00 2001 From: jeanlyn Date: Mon, 2 Feb 2015 10:10:36 +0800 Subject: [PATCH] Insert a space after the start of the comment --- .../main/scala/org/apache/spark/sql/hive/TableReader.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala index 8f955b699981e..72edb89ad3358 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala @@ -188,7 +188,7 @@ class HadoopTableReader( val hconf = broadcastedHiveConf.value.value val deserializer = localDeserializer.newInstance() deserializer.initialize(hconf, partProps) - //get the table deserializer + // get the table deserializer val tableSerDe = tableDesc.getDeserializerClass.newInstance() tableSerDe.initialize(hconf, tableDesc.getProperties) @@ -280,7 +280,7 @@ private[hive] object HadoopTableReader extends HiveInspectors { val soi = convertdeserializer match { case Some(convert) => - //check need to convert + // check need to convert if (deserializer.getObjectInspector.equals(convert.getObjectInspector)) { deserializer.getObjectInspector().asInstanceOf[StructObjectInspector] } @@ -345,7 +345,7 @@ private[hive] object HadoopTableReader extends HiveInspectors { if (deserializer.getObjectInspector.equals(convert.getObjectInspector)) { deserializer.deserialize(value) } - //If partition schema does not match table schema, update the row to match + // If partition schema does not match table schema, update the row to match else { partTblObjectInspectorConverter.convert(deserializer.deserialize(value)) }