From 7b9957986128d3dc7dd9da01e963cb3b244f8cf3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BA=BA=E7=94=9F=E6=9C=89=E5=A6=82=E4=B8=A4=E4=B8=AA?= =?UTF-8?q?=E6=A9=98=E5=AD=90?= <15764973965@163.com> Date: Wed, 8 Nov 2023 16:12:52 +0800 Subject: [PATCH] add import `org.apache.spark.sql.api.python.*` (#4961) --- .../spark/src/main/resources/python/mix_pyspark.py | 1 + 1 file changed, 1 insertion(+) diff --git a/linkis-engineconn-plugins/spark/src/main/resources/python/mix_pyspark.py b/linkis-engineconn-plugins/spark/src/main/resources/python/mix_pyspark.py index adbf5ecad6..9426ed867a 100644 --- a/linkis-engineconn-plugins/spark/src/main/resources/python/mix_pyspark.py +++ b/linkis-engineconn-plugins/spark/src/main/resources/python/mix_pyspark.py @@ -118,6 +118,7 @@ def isImportAllPackageUnderSparkSql(self): java_import(gateway.jvm, "org.apache.spark.api.java.*") java_import(gateway.jvm, "org.apache.spark.api.python.*") java_import(gateway.jvm, "org.apache.spark.mllib.api.python.*") +java_import(gateway.jvm, "org.apache.spark.sql.api.python.*") intp = gateway.entry_point