Skip to content

Commit

Permalink
address review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
zhzhan committed Sep 17, 2014
1 parent f4af934 commit 9412d24
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -28,10 +28,10 @@ import org.apache.spark.sql.catalyst.analysis
import org.apache.spark.sql.catalyst.expressions._
import org.apache.spark.sql.catalyst.types._
import org.apache.spark.util.Utils.getContextOrSparkClassLoader
import org.apache.spark.sql.hive.HiveShim

/* Implicit conversions */
import scala.collection.JavaConversions._
import org.apache.spark.sql.hive.HiveShim

private[hive] abstract class HiveFunctionRegistry
extends analysis.FunctionRegistry with HiveInspectors {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ object HiveShim {
/*handle the difference in "None" and empty ""*/
def getEmptyCommentsFieldValue = "None"

def convertCatalystString2Hive(s: String) = new hadoopIo.Text(s)
def convertCatalystString2Hive(s: String) = new hadoopIo.Text(s) // TODO why should be Text?

def getCommandProcessor(cmd: Array[String], conf: HiveConf) = {
CommandProcessorFactory.get(cmd(0), conf)
Expand Down

0 comments on commit 9412d24

Please sign in to comment.