[analytics-engine] Wire PPL spath end-to-end through the analytics-engine route

sandbox/libs/analytics-framework/src/main/java/org/opensearch/analytics/spi/FieldType.java

@@ -64,7 +64,20 @@ public enum FieldType {
      * placeholder; {@link #fromMappingType} keeps working unchanged because no source
      * advertises that mapping string.
      */
-    ARRAY("array");
+    ARRAY("array"),
+
+    /**
+     * Map-typed expression result. First in-tree producer is PPL `spath`'s auto-extract mode
+     * (`JSON_EXTRACT_ALL` returns {@code MAP<VARCHAR, VARCHAR>}). Mapping string is {@code
+     * "map"} as a placeholder — no OpenSearch storage format declares this mapping today, so
+     * {@link #fromMappingType} never resolves to it through the mapping path; columns reach
+     * MAP only through {@link #fromSqlTypeName}. Capability registrations for filter / project
+     * operators on MAP columns are intentionally minimal: callers (e.g. PPL `where doc.user.name`)
+     * always wrap the MAP column in an ITEM lookup whose result type is the map's value type,
+     * so the EQUALS / sort / aggregate operators see the value-level type by the time the
+     * runtime executes them.
+     */
+    MAP("map");
 
     private final String mappingType;
 
@@ -127,6 +140,7 @@ public static FieldType fromSqlTypeName(SqlTypeName sqlTypeName) {
             case BOOLEAN -> FieldType.BOOLEAN;
             case BINARY, VARBINARY -> FieldType.BINARY;
             case ARRAY -> FieldType.ARRAY;
+            case MAP -> FieldType.MAP;
             default -> null;
         };
     }

sandbox/libs/analytics-framework/src/main/java/org/opensearch/analytics/spi/ScalarFunction.java

@@ -233,6 +233,7 @@ public enum ScalarFunction {
     JSON_DELETE(Category.SCALAR, SqlKind.OTHER_FUNCTION),
     JSON_EXTEND(Category.SCALAR, SqlKind.OTHER_FUNCTION),
     JSON_EXTRACT(Category.SCALAR, SqlKind.OTHER_FUNCTION),
+    JSON_EXTRACT_ALL(Category.SCALAR, SqlKind.OTHER_FUNCTION),
     JSON_KEYS(Category.SCALAR, SqlKind.OTHER_FUNCTION),
     JSON_SET(Category.SCALAR, SqlKind.OTHER_FUNCTION),