Update the pyspark related binding object

Signed-off-by: acezen <qiaozi.zwb@alibaba-inc.com>
apache · Mar 28, 2024 · 812d4df · 812d4df
1 parent 1836ce2
commit 812d4df
Show file tree

Hide file tree

Showing 6 changed files with 7 additions and 7 deletions.
diff --git a/pyspark/graphar_pyspark/__init__.py b/pyspark/graphar_pyspark/__init__.py
@@ -40,7 +40,7 @@ def set_spark_session(self, spark_session: SparkSession) -> None:
         self.ss = spark_session  # Python SparkSession
         self.sc = spark_session.sparkContext  # Python SparkContext
         self.jvm = spark_session._jvm  # JVM
-        self.graphar = spark_session._jvm.com.alibaba.graphar  # Alias to scala graphar
+        self.graphar = spark_session._jvm.org.apache.graphar  # Alias to scala graphar
         self.jsc = spark_session._jsc  # Java SparkContext
         self.jss = spark_session._jsparkSession  # Java SparkSession
 

diff --git a/pyspark/graphar_pyspark/graph.py b/pyspark/graphar_pyspark/graph.py
@@ -15,7 +15,7 @@
 # specific language governing permissions and limitations
 # under the License.
 
-"""Bidnings to com.alibaba.graphar.graph."""
+"""Bidnings to org.apache.graphar.graph."""
 
 from __future__ import annotations
 
@@ -188,7 +188,7 @@ def write(
     ) -> None:
         """Write graph data in graphar format.
 
-        Note: for default parameters check com.alibaba.graphar.GeneralParams;
+        Note: for default parameters check org.apache.graphar.GeneralParams;
         For this method None for any of arguments means that the default value will be used.
 
         :param path: the directory to write.

diff --git a/pyspark/graphar_pyspark/info.py b/pyspark/graphar_pyspark/info.py
@@ -29,7 +29,7 @@
 # see the license for the specific language governing permissions and
 # limitations under the license.
 
-"""Bindings to com.alibaba.graphar info classes."""
+"""Bindings to org.apache.graphar info classes."""
 
 # because we are using type-hints, we need to define few custom TypeVar
 # to describe returns of classmethods;

diff --git a/pyspark/graphar_pyspark/reader.py b/pyspark/graphar_pyspark/reader.py
@@ -29,7 +29,7 @@
 # see the license for the specific language governing permissions and
 # limitations under the license.
 
-"""Bidnings to com.alibaba.graphar.graph."""
+"""Bidnings to org.apache.graphar.graph."""
 
 from __future__ import annotations
 

diff --git a/pyspark/graphar_pyspark/util.py b/pyspark/graphar_pyspark/util.py
@@ -29,7 +29,7 @@
 # see the license for the specific language governing permissions and
 # limitations under the license.
 
-"""Bindings to com.alibaba.graphar.util."""
+"""Bindings to org.apache.graphar.util."""
 
 from __future__ import annotations
 

diff --git a/pyspark/graphar_pyspark/writer.py b/pyspark/graphar_pyspark/writer.py
@@ -29,7 +29,7 @@
 # see the license for the specific language governing permissions and
 # limitations under the license.
 
-"""Bindings to com.alibaba.graphar.writer."""
+"""Bindings to org.apache.graphar.writer."""
 
 
 from __future__ import annotations