From b726f8f331d078feef9af470c250d2f4a1fcea9c Mon Sep 17 00:00:00 2001 From: chenheng Date: Tue, 29 Dec 2015 11:19:13 +0800 Subject: [PATCH] HIVE-12753 Improve performance of LazyBinaryColumnarSerDe for Text strings --- .../org/apache/hadoop/hive/serde2/columnar/LazyBinaryColumnarSerDe.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/serde/src/java/org/apache/hadoop/hive/serde2/columnar/LazyBinaryColumnarSerDe.java b/serde/src/java/org/apache/hadoop/hive/serde2/columnar/LazyBinaryColumnarSerDe.java index 092bff8..cddd5de 100644 --- a/serde/src/java/org/apache/hadoop/hive/serde2/columnar/LazyBinaryColumnarSerDe.java +++ b/serde/src/java/org/apache/hadoop/hive/serde2/columnar/LazyBinaryColumnarSerDe.java @@ -110,7 +110,7 @@ public Writable serialize(Object obj, ObjectInspector objInspector) throws SerDe if ((f != null) && (foi.getCategory().equals(ObjectInspector.Category.PRIMITIVE)) && ((PrimitiveObjectInspector) foi).getPrimitiveCategory().equals( PrimitiveObjectInspector.PrimitiveCategory.STRING) - && ((StringObjectInspector) foi).getPrimitiveJavaObject(f).length() == 0) { + && ((StringObjectInspector) foi).getPrimitiveWritableObject(f).getLength() == 0) { serializeStream.write(INVALID_UTF__SINGLE_BYTE, 0, 1); } else { LazyBinarySerDe.serialize(serializeStream, f, foi, true, warnedOnceNullMapKey); -- 1.9.3 (Apple Git-50)