rename variable names

Author: yuxiqian

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java

@@ -45,21 +45,21 @@
 public class TransformExpressionKey implements Serializable {
     private static final long serialVersionUID = 1L;
     @Nullable private final String originalExpression;
-    private final String expression;
+    private final String compiledExpression;
     private final List<String> argumentNames;
     private final List<Class<?>> argumentClasses;
     private final Class<?> returnClass;
     private final Map<String, String> columnNameMap;
 
     private TransformExpressionKey(
             @Nullable String originalExpression,
-            String expression,
+            String compiledExpression,
             List<String> argumentNames,
             List<Class<?>> argumentClasses,
             Class<?> returnClass,
             Map<String, String> columnNameMap) {
         this.originalExpression = originalExpression;
-        this.expression = expression;
+        this.compiledExpression = compiledExpression;
         this.argumentNames = argumentNames;
         this.argumentClasses = argumentClasses;
         this.returnClass = returnClass;
@@ -71,12 +71,12 @@ public String getOriginalExpression() {
         return originalExpression;
     }
 
-    public String getExpression() {
-        return expression;
+    public String getCompiledExpression() {
+        return compiledExpression;
     }
 
     public String getFullExpression() {
-        return JaninoCompiler.loadSystemFunction(expression);
+        return JaninoCompiler.loadSystemFunction(compiledExpression);
     }
 
     public List<String> getArgumentNames() {
@@ -97,14 +97,14 @@ public Map<String, String> getColumnNameMap() {
 
     public static TransformExpressionKey of(
             @Nullable String originalExpression,
-            String expression,
+            String compiledExpression,
             List<String> argumentNames,
             List<Class<?>> argumentClasses,
             Class<?> returnClass,
             Map<String, String> columnNameMap) {
         return new TransformExpressionKey(
                 originalExpression,
-                expression,
+                compiledExpression,
                 argumentNames,
                 argumentClasses,
                 returnClass,
@@ -121,7 +121,7 @@ public boolean equals(Object o) {
         }
         TransformExpressionKey that = (TransformExpressionKey) o;
         return Objects.equals(originalExpression, that.originalExpression)
-                && expression.equals(that.expression)
+                && compiledExpression.equals(that.compiledExpression)
                 && argumentNames.equals(that.argumentNames)
                 && argumentClasses.equals(that.argumentClasses)
                 && returnClass.equals(that.returnClass)
@@ -132,7 +132,7 @@ public boolean equals(Object o) {
     public int hashCode() {
         return Objects.hash(
                 originalExpression,
-                expression,
+                compiledExpression,
                 argumentNames,
                 argumentClasses,
                 returnClass,
@@ -145,8 +145,8 @@ public String toString() {
                 + "originalExpression='"
                 + originalExpression
                 + '\''
-                + ", expression='"
-                + expression
+                + ", compiledExpression='"
+                + compiledExpression
                 + '\''
                 + ", argumentNames="
                 + argumentNames

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilterProcessor.java

@@ -128,7 +128,7 @@ public boolean test(Object[] preRow, Object[] postRow, TransformContext context)
                                     ? transformExpressionKey.getOriginalExpression()
                                     : "<no op>",
                             transformExpressionKey != null
-                                    ? transformExpressionKey.getExpression()
+                                    ? transformExpressionKey.getCompiledExpression()
                                     : "<no op>",
                             transformFilter.getColumnNameMapAsString()),
                     e);