opensearch-project
diff --git a/‎core/src/main/java/org/opensearch/sql/calcite/CalciteRelNodeVisitor.java‎
Lines changed: 38 additions & 12 deletions b/‎core/src/main/java/org/opensearch/sql/calcite/CalciteRelNodeVisitor.java‎
Lines changed: 38 additions & 12 deletions
diff --git a/‎core/src/main/java/org/opensearch/sql/utils/WildcardRenameUtils.java‎
Lines changed: 141 additions & 0 deletions b/‎core/src/main/java/org/opensearch/sql/utils/WildcardRenameUtils.java‎
Lines changed: 141 additions & 0 deletions
@@ -138,6 +138,7 @@
 import org.opensearch.sql.expression.function.PPLFuncImpTable;
 import org.opensearch.sql.expression.parse.RegexCommonUtils;
 import org.opensearch.sql.utils.ParseUtils;
+import org.opensearch.sql.utils.WildcardRenameUtils;
 
 public class CalciteRelNodeVisitor extends AbstractNodeVisitor<RelNode, CalcitePlanContext> {
 
@@ -487,27 +488,52 @@ public RelNode visitRename(Rename node, CalcitePlanContext context) {
     visitChildren(node, context);
     List<String> originalNames = context.relBuilder.peek().getRowType().getFieldNames();
     List<String> newNames = new ArrayList<>(originalNames);
+
     for (org.opensearch.sql.ast.expression.Map renameMap : node.getRenameList()) {
-      if (renameMap.getTarget() instanceof Field) {
-        Field t = (Field) renameMap.getTarget();
-        String newName = t.getField().toString();
-        RexNode check = rexVisitor.analyze(renameMap.getOrigin(), context);
-        if (check instanceof RexInputRef) {
-          RexInputRef ref = (RexInputRef) check;
-          newNames.set(ref.getIndex(), newName);
-        } else {
-          throw new SemanticCheckException(
-              String.format("the original field %s cannot be resolved", renameMap.getOrigin()));
-        }
-      } else {
+      if (!(renameMap.getTarget() instanceof Field)) {
         throw new SemanticCheckException(
             String.format("the target expected to be field, but is %s", renameMap.getTarget()));
       }
+
+      String sourcePattern = ((Field) renameMap.getOrigin()).getField().toString();
+      String targetPattern = ((Field) renameMap.getTarget()).getField().toString();
+
+      if (WildcardRenameUtils.isWildcardPattern(sourcePattern)
+          && !WildcardRenameUtils.validatePatternCompatibility(sourcePattern, targetPattern)) {
+        throw new SemanticCheckException(
+            "Source and target patterns have different wildcard counts");
+      }
+
+      List<String> matchingFields = WildcardRenameUtils.matchFieldNames(sourcePattern, newNames);
+
+      for (String fieldName : matchingFields) {
+        String newName =
+            WildcardRenameUtils.applyWildcardTransformation(
+                sourcePattern, targetPattern, fieldName);
+        if (newNames.contains(newName) && !newName.equals(fieldName)) {
+          removeFieldIfExists(newName, newNames, context);
+        }
+        int fieldIndex = newNames.indexOf(fieldName);
+        if (fieldIndex != -1) {
+          newNames.set(fieldIndex, newName);
+        }
+      }
+
+      if (matchingFields.isEmpty() && newNames.contains(targetPattern)) {
+        removeFieldIfExists(targetPattern, newNames, context);
+        context.relBuilder.rename(newNames);
+      }
     }
     context.relBuilder.rename(newNames);
     return context.relBuilder.peek();
   }
 
+  private void removeFieldIfExists(
+      String fieldName, List<String> newNames, CalcitePlanContext context) {
+    newNames.remove(fieldName);
+    context.relBuilder.projectExcept(context.relBuilder.field(fieldName));
+  }
+
   @Override
   public RelNode visitSort(Sort node, CalcitePlanContext context) {
     visitChildren(node, context);
 
@@ -0,0 +1,141 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package org.opensearch.sql.utils;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/** Utility class for handling wildcard patterns in rename operations. */
+public class WildcardRenameUtils {
+
+  /**
+   * Check if pattern contains any supported wildcards.
+   *
+   * @param pattern the pattern to check
+   * @return true if pattern contains * wildcards
+   */
+  public static boolean isWildcardPattern(String pattern) {
+    return pattern.contains("*");
+  }
+
+  /**
+   * Check if pattern is only wildcards that matches all fields.
+   *
+   * @param pattern the pattern to check
+   * @return true if pattern is only made up of wildcards "*"
+   */
+  public static boolean isFullWildcardPattern(String pattern) {
+    return pattern.matches("\\*+");
+  }
+
+  /**
+   * Convert wildcard pattern to regex.
+   *
+   * @param pattern the wildcard pattern
+   * @return regex pattern with capture groups
+   */
+  public static String wildcardToRegex(String pattern) {
+    String[] parts = pattern.split("\\*", -1);
+    return Arrays.stream(parts).map(Pattern::quote).collect(Collectors.joining("(.*)"));
+  }
+
+  /**
+   * Match field names against wildcard pattern.
+   *
+   * @param wildcardPattern the pattern to match against
+   * @param availableFields collection of available field names
+   * @return list of matching field names
+   */
+  public static List<String> matchFieldNames(
+      String wildcardPattern, Collection<String> availableFields) {
+    // Single wildcard matches all available fields
+    if (isFullWildcardPattern(wildcardPattern)) {
+      return new ArrayList<>(availableFields);
+    }
+
+    String regexPattern = "^" + wildcardToRegex(wildcardPattern) + "$";
+    Pattern pattern = Pattern.compile(regexPattern);
+
+    return availableFields.stream()
+        .filter(field -> pattern.matcher(field).matches())
+        .collect(Collectors.toList());
+  }
+
+  /**
+   * Apply wildcard transformation to get new field name.
+   *
+   * @param sourcePattern the source wildcard pattern
+   * @param targetPattern the target wildcard pattern
+   * @param actualFieldName the actual field name to transform
+   * @return transformed field name
+   * @throws IllegalArgumentException if patterns don't match or are invalid
+   */
+  public static String applyWildcardTransformation(
+      String sourcePattern, String targetPattern, String actualFieldName) {
+
+    if (sourcePattern.equals(targetPattern)) {
+      return actualFieldName;
+    }
+
+    if (!isFullWildcardPattern(sourcePattern) || !isFullWildcardPattern(targetPattern)) {
+      if (sourcePattern.matches(".*\\*{2,}.*") || targetPattern.matches(".*\\*{2,}.*")) {
+        throw new IllegalArgumentException("Consecutive wildcards in pattern are not supported");
+      }
+    }
+
+    String sourceRegex = "^" + wildcardToRegex(sourcePattern) + "$";
+    Matcher matcher = Pattern.compile(sourceRegex).matcher(actualFieldName);
+
+    if (!matcher.matches()) {
+      throw new IllegalArgumentException(
+          String.format("Field '%s' does not match pattern '%s'", actualFieldName, sourcePattern));
+    }
+
+    String result = targetPattern;
+
+    for (int i = 1; i <= matcher.groupCount(); i++) {
+      String capturedValue = matcher.group(i);
+
+      int index = result.indexOf("*");
+      if (index >= 0) {
+        result = result.substring(0, index) + capturedValue + result.substring(index + 1);
+      } else {
+        throw new IllegalArgumentException(
+            "Target pattern has fewer wildcards than source pattern");
+      }
+    }
+
+    return result;
+  }
+
+  /**
+   * Validate that source and target patterns have matching wildcard counts.
+   *
+   * @param sourcePattern the source pattern
+   * @param targetPattern the target pattern
+   * @return true if patterns are compatible
+   */
+  public static boolean validatePatternCompatibility(String sourcePattern, String targetPattern) {
+    int sourceWildcards = countWildcards(sourcePattern);
+    int targetWildcards = countWildcards(targetPattern);
+    return sourceWildcards == targetWildcards;
+  }
+
+  /**
+   * Count the number of wildcards in a pattern.
+   *
+   * @param pattern the pattern to analyze
+   * @return number of wildcard characters
+   */
+  private static int countWildcards(String pattern) {
+    return (int) pattern.chars().filter(ch -> ch == '*').count();
+  }
+}