Fix TextConverter inefficiency

amplab · Apr 19, 2012 · bc14411 · bc14411
1 parent 5704958
commit bc14411
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...pache/hadoop/hive/serde2/objectinspector/primitive/PrimitiveObjectInspectorConverter.java b/...pache/hadoop/hive/serde2/objectinspector/primitive/PrimitiveObjectInspectorConverter.java
@@ -289,7 +289,11 @@ public Text convert(Object input) {
         t.set(String.valueOf(((DoubleObjectInspector) inputOI).get(input)));
         return t;
       case STRING:
-        t.set(((StringObjectInspector) inputOI).getPrimitiveJavaObject(input));
+	if (inputOI.preferWritable()) {
+	  t.set(((StringObjectInspector) inputOI).getPrimitiveWritableObject(input));
+	} else {
+	  t.set(((StringObjectInspector) inputOI).getPrimitiveJavaObject(input));
+	}
         return t;
       default:
         throw new RuntimeException("Hive 2 Internal error: type = " + inputOI.getTypeName());