solve review comments

Author: zhzhan

sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala

@@ -304,12 +304,7 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
           driver.setMaxRows(maxRows)
           driver.getResults(results)
           driver.close()
-          results.map { r =>
-            r match {
-              case s: String => s
-              case o => o.toString
-            }
-          }
+          HiveShim.processResults(results)
         case _ =>
           sessionState.out.println(tokens(0) + " " + cmd_1)
           Seq(proc.run(cmd_1).getResponseCode.toString)

sql/hive/v0.12.0/src/main/scala/org/apache/spark/sql/hive/Shim.scala

@@ -52,6 +52,8 @@ private[hive] object HiveShim {
 
   def createDriverResultsArray = new JArrayList[String]
 
+  def processResults(results: JArrayList[String]) = results
+
   def getStatsSetupConstTotalSize = StatsSetupConst.TOTAL_SIZE
 
   def createDefaultDBIfNeeded(context: HiveContext) = {  }

sql/hive/v0.13.1/src/main/scala/org/apache/spark/sql/hive/Shim.scala

@@ -56,6 +56,15 @@ private[hive] object HiveShim {
 
   def createDriverResultsArray = new JArrayList[Object]
 
+  def processResults(results: JArrayList[Object]) = {
+    results.map { r =>
+      r match {
+        case s: String => s
+        case a: Array[Object] => a(0).asInstanceOf[String]
+      }
+    }
+  }
+
   def getStatsSetupConstTotalSize = StatsSetupConst.TOTAL_SIZE
 
   def createDefaultDBIfNeeded(context: HiveContext) = {