Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r181569225
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala ---
@@ -3189,10 +3189,10 @@ class Dataset[T] private[sql](
private[sql]
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/21007
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r181109214
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3071,64 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r181103949
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3071,64 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r181083759
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3071,64 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r181078856
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3071,64 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r181078329
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3071,64 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r181077809
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala
---
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r181067958
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3071,64 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r181066593
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala
---
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache
Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180829993
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala
---
@@ -0,0 +1,45 @@
+/*
--- End diff --
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180710305
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala
---
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180705768
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala
---
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180614280
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala
---
@@ -0,0 +1,45 @@
+/*
--- End diff --
I
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180602148
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala
---
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache
Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180584581
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala
---
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache
Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180584207
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3062,73 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180583899
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3062,73 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180585895
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/TestQueryExecutionListener.scala
---
@@ -0,0 +1,45 @@
+/*
--- End diff --
Is
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180386274
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3062,73 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180383755
--- Diff: python/pyspark/sql/tests.py ---
@@ -3062,6 +3062,73 @@ def
test_sparksession_with_stopped_sparkcontext(self):
sc.stop()
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180337840
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala ---
@@ -3312,10 +3313,15 @@ class Dataset[T] private[sql](
/** Convert to
Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21007#discussion_r180333465
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala ---
@@ -3189,10 +3189,10 @@ class Dataset[T] private[sql](
private[sql] def
GitHub user HyukjinKwon opened a pull request:
https://github.com/apache/spark/pull/21007
[SPARK-23942][PYTHON][SQL] Makes collect in PySpark as action for a query
executor listener
## What changes were proposed in this pull request?
This PR proposes to add `collect` to a
24 matches
Mail list logo
