From df0d1f4621a6ca46f3688f0e61092f9be199b9b9 Mon Sep 17 00:00:00 2001 From: Roberto Congiu Date: Thu, 4 Oct 2012 16:12:36 -0700 Subject: [PATCH] fixed issue using float, issue #13 --- pom.xml | 2 +- src/main/java/org/openx/data/jsonserde/JsonSerDe.java | 4 ++-- .../objectinspector/JsonObjectInspectorFactory.java | 5 ++++- src/test/scripts/nested_test.sql | 2 +- 4 files changed, 8 insertions(+), 5 deletions(-) diff --git a/pom.xml b/pom.xml index b0fa6af2..f6299b27 100644 --- a/pom.xml +++ b/pom.xml @@ -5,7 +5,7 @@ org.openx.data json-serde - 1.1.2 + 1.1.3 jar openx-json-serde diff --git a/src/main/java/org/openx/data/jsonserde/JsonSerDe.java b/src/main/java/org/openx/data/jsonserde/JsonSerDe.java index 2631c4ef..c76d8b7a 100644 --- a/src/main/java/org/openx/data/jsonserde/JsonSerDe.java +++ b/src/main/java/org/openx/data/jsonserde/JsonSerDe.java @@ -46,7 +46,7 @@ import org.apache.hadoop.hive.serde2.objectinspector.primitive.StringObjectInspector; import org.apache.hadoop.hive.serde2.typeinfo.StructTypeInfo; import org.apache.hadoop.io.Text; -import org.json.JSONArray; +import org.openx.data.jsonserde.json.JSONArray; import org.openx.data.jsonserde.json.JSONException; import org.openx.data.jsonserde.json.JSONObject; import org.openx.data.jsonserde.objectinspector.JsonObjectInspectorFactory; @@ -342,7 +342,7 @@ private JSONArray serializeList(Object obj, ListObjectInspector loi) { Object element = loi.getListElement(obj, i); try { ar.put(i, serializeField(element, loi.getListElementObjectInspector() ) ); - } catch (org.json.JSONException ex) { + } catch (JSONException ex) { LOG.warn("Problem serializing array", ex); throw new RuntimeException(ex); } diff --git a/src/main/java/org/openx/data/jsonserde/objectinspector/JsonObjectInspectorFactory.java b/src/main/java/org/openx/data/jsonserde/objectinspector/JsonObjectInspectorFactory.java index e289dc4a..2d2584ee 100644 --- a/src/main/java/org/openx/data/jsonserde/objectinspector/JsonObjectInspectorFactory.java +++ b/src/main/java/org/openx/data/jsonserde/objectinspector/JsonObjectInspectorFactory.java @@ -46,8 +46,11 @@ public static ObjectInspector getJsonObjectInspectorFromTypeInfo( if (result == null) { switch (typeInfo.getCategory()) { case PRIMITIVE: { + PrimitiveTypeInfo pti = (PrimitiveTypeInfo) typeInfo; + result = - getPrimitiveJavaObjectInspector(((PrimitiveTypeInfo) typeInfo).getPrimitiveCategory()); + getPrimitiveJavaObjectInspector( pti.getPrimitiveCategory().equals(PrimitiveCategory.FLOAT) ? + PrimitiveCategory.DOUBLE : pti.getPrimitiveCategory() ); break; } case LIST: { diff --git a/src/test/scripts/nested_test.sql b/src/test/scripts/nested_test.sql index 0a1892ae..61d379a3 100644 --- a/src/test/scripts/nested_test.sql +++ b/src/test/scripts/nested_test.sql @@ -1,4 +1,4 @@ -add jar ../../../target/json-serde-1.0-SNAPSHOT-jar-with-dependencies.jar; +add jar ../../../target/json-serde-1.1.3-jar-with-dependencies.jar; DROP TABLE json_nested_test; CREATE TABLE json_nested_test (