File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
src/main/scala/org/apache/spark/sql/hive
v0.12.0/src/main/scala/org/apache/spark/sql/hive Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -28,10 +28,10 @@ import org.apache.spark.sql.catalyst.analysis
2828import org .apache .spark .sql .catalyst .expressions ._
2929import org .apache .spark .sql .catalyst .types ._
3030import org .apache .spark .util .Utils .getContextOrSparkClassLoader
31+ import org .apache .spark .sql .hive .HiveShim
3132
3233/* Implicit conversions */
3334import scala .collection .JavaConversions ._
34- import org .apache .spark .sql .hive .HiveShim
3535
3636private [hive] abstract class HiveFunctionRegistry
3737 extends analysis.FunctionRegistry with HiveInspectors {
Original file line number Diff line number Diff line change @@ -49,7 +49,7 @@ object HiveShim {
4949 /* handle the difference in "None" and empty ""*/
5050 def getEmptyCommentsFieldValue = " None"
5151
52- def convertCatalystString2Hive (s : String ) = new hadoopIo.Text (s)
52+ def convertCatalystString2Hive (s : String ) = new hadoopIo.Text (s) // TODO why should be Text?
5353
5454 def getCommandProcessor (cmd : Array [String ], conf : HiveConf ) = {
5555 CommandProcessorFactory .get(cmd(0 ), conf)
You can’t perform that action at this time.
0 commit comments