[Feature][Transform][python] init PythonOperationProxy

Author: FuYouJ

Diff for: seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/jsonpath/SingletonServer.java

@@ -0,0 +1,21 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.seatunnel.transform.jsonpath;
+
+
+public class SingletonServer {
+}

Diff for: seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonOperationProxy.java

@@ -17,4 +17,30 @@
 
 package org.apache.seatunnel.transform.python;
 
-public class PythonOperationProxy implements RowOperation {}
+import py4j.GatewayServer;
+
+public class PythonOperationProxy implements RowOperation {
+
+    private GatewayServer javaServer;
+    private PythonOperationProxy(){
+        if (INSTANCE != null) {
+            throw new RuntimeException("Please use newInstance() method for getting the single instance of this class.");
+        }
+    }
+    private static volatile PythonOperationProxy INSTANCE;
+    public static PythonOperationProxy newInstance(Integer javaServerPort) {
+        if (INSTANCE == null){
+            synchronized (PythonOperationProxy.class){
+                if (INSTANCE == null){
+                    PythonOperationProxy operationProxy = new PythonOperationProxy();
+                    operationProxy.javaServer = new GatewayServer(operationProxy,javaServerPort);
+                }
+            }
+        }
+        return INSTANCE;
+    }
+
+    public void shutdown(){
+        this.javaServer.shutdown();
+    }
+}

Diff for: seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonTransform.java

@@ -13,9 +13,16 @@ public class PythonTransform extends MultipleFieldOutputTransform {
 
     private final PythonTransformConfig config;
 
+    private final PythonOperationProxy pythonOperationProxy;
+
     public PythonTransform(@NonNull CatalogTable inputCatalogTable, PythonTransformConfig transformConfig) {
         super(inputCatalogTable, transformConfig.getErrorHandleWay());
         this.config = transformConfig;
+        pythonOperationProxy = initLocalSingletonJavaServer(config.getJavaServerPort());
+    }
+
+    private PythonOperationProxy initLocalSingletonJavaServer(Integer javaServerPort) {
+        return PythonOperationProxy.newInstance(javaServerPort);
     }
 
     @Override

Diff for: seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/python/PythonTransformConfig.java

@@ -105,8 +105,7 @@ public static PythonTransformConfig of(ReadonlyConfig config) {
     private static String loadCodeFromPath(String filePath) {
         try {
             // 读取整个文件内容到字符串
-            String code = new String(Files.readAllBytes(Paths.get(filePath)));
-            return code;
+            return new String(Files.readAllBytes(Paths.get(filePath)));
         } catch (IOException e) {
             // 处理可能发生的IO异常
             throw new TransformException(LOAD_SOURCE_CODE_FROM_PATH_ERROR,