Elasticsearch geo_point type support by converting to varchar (#2244)

Author: VenkatasivareddyTR

athena-elasticsearch/src/main/java/com/amazonaws/athena/connectors/elasticsearch/ElasticsearchSchemaUtils.java

@@ -147,6 +147,7 @@ private static FieldType toFieldType(Map<String, Object> mapping)
             case "text":
             case "keyword":
             case "binary":
+            case "geo_point":
                 minorType = Types.MinorType.VARCHAR;
                 break;
             case "long":

athena-elasticsearch/src/main/java/com/amazonaws/athena/connectors/elasticsearch/ElasticsearchTypeUtils.java

@@ -120,14 +120,8 @@ private Extractor makeVarCharExtractor(Field field)
             if (fieldValue instanceof String) {
                 dst.value = (String) fieldValue;
             }
-            else if (fieldValue instanceof List) {
-                Object value = ((List) fieldValue).get(0);
-                if (value instanceof String) {
-                    dst.value = (String) value;
-                }
-                else {
-                    dst.isSet = 0;
-                }
+            else if (fieldValue instanceof List || fieldValue instanceof Map) {
+                dst.value = fieldValue.toString();
             }
             else {
                 dst.isSet = 0;

athena-elasticsearch/src/test/java/com/amazonaws/athena/connectors/elasticsearch/ElasticsearchTypeUtilsTest.java

@@ -92,7 +92,7 @@ public void makeVarCharExtractorTest()
 
         Map<String, Object> expectedResults = ImmutableMap.of(
                 "mytext", "My favorite Sci-Fi movie is Interstellar.",
-                "mytextlist", "Hey, this is an array!");
+                "mytextlist", "[Hey, this is an array!, Wasn't expecting this!]");
         Map<String, Object> extractedResults = testField(mapping, document);
         logger.info("makeVarCharExtractorTest - Expected: {}, Extracted: {}", expectedResults, extractedResults);
         assertEquals("Extracted results are not as expected!", expectedResults, extractedResults);