This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 069fa1eebe9 [MINOR][CONNECT] Fix typos in connect/plan.py
069fa1eebe9 is described below
commit 069fa1eebe97d7ca4dde7cd87ef385d4857ffaad
Author: Sandeep Singh <[email protected]>
AuthorDate: Thu Jan 5 14:34:41 2023 +0900
[MINOR][CONNECT] Fix typos in connect/plan.py
### What changes were proposed in this pull request?
Fixing typos in connect/plan.py
### Why are the changes needed?
Typos
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
just fixing typos
Closes #39397 from techaddict/typo-in-createview.
Authored-by: Sandeep Singh <[email protected]>
Signed-off-by: Hyukjin Kwon <[email protected]>
---
python/pyspark/sql/connect/plan.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/python/pyspark/sql/connect/plan.py
b/python/pyspark/sql/connect/plan.py
index f63e39c7f3e..a6d1ad4068b 100644
--- a/python/pyspark/sql/connect/plan.py
+++ b/python/pyspark/sql/connect/plan.py
@@ -1227,7 +1227,7 @@ class CreateView(LogicalPlan):
) -> None:
super().__init__(child)
self._name = name
- self._is_gloal = is_global
+ self._is_global = is_global
self._replace = replace
def command(self, session: "SparkConnectClient") -> proto.Command:
@@ -1235,7 +1235,7 @@ class CreateView(LogicalPlan):
plan = proto.Command()
plan.create_dataframe_view.replace = self._replace
- plan.create_dataframe_view.is_global = self._is_gloal
+ plan.create_dataframe_view.is_global = self._is_global
plan.create_dataframe_view.name = self._name
plan.create_dataframe_view.input.CopyFrom(self._child.plan(session))
return plan
@@ -1587,7 +1587,7 @@ class RecoverPartitions(LogicalPlan):
# self._table_name = table_name
#
# def plan(self, session: "SparkConnectClient") -> proto.Relation:
-# plan =
proto.Relation(catalog=proto.Catalog(is_cached=proto.IsCahed()))
+# plan =
proto.Relation(catalog=proto.Catalog(is_cached=proto.IsCached()))
# plan.catalog.is_cached.table_name = self._table_name
# return plan
#
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
