Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/22442
---
-
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/22442#discussion_r220407196
--- Diff: python/pyspark/sql/functions.py ---
@@ -2328,11 +2328,14 @@ def to_json(col, options={}):
@ignore_unicode_prefix
@since(2.4)
Github user MaxGekk commented on a diff in the pull request:
https://github.com/apache/spark/pull/22442#discussion_r219403620
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -3611,6 +3611,20 @@ object functions {
*/
def schema_of_json(e:
Github user rxin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22442#discussion_r219297029
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -3611,6 +3611,20 @@ object functions {
*/
def schema_of_json(e:
Github user MaxGekk commented on a diff in the pull request:
https://github.com/apache/spark/pull/22442#discussion_r218801255
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -3611,6 +3611,20 @@ object functions {
*/
def schema_of_json(e:
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/22442#discussion_r218778695
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -3611,6 +3611,20 @@ object functions {
*/
def
Github user MaxGekk commented on a diff in the pull request:
https://github.com/apache/spark/pull/22442#discussion_r218748820
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -3611,6 +3611,20 @@ object functions {
*/
def schema_of_json(e:
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/22442#discussion_r218642844
--- Diff: sql/core/src/test/resources/sql-tests/inputs/json-functions.sql
---
@@ -56,3 +56,8 @@ select from_json('[{"a": 1}, 2]',
'array>');
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/22442#discussion_r218642815
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -3611,6 +3611,20 @@ object functions {
*/
def
Github user MaxGekk commented on a diff in the pull request:
https://github.com/apache/spark/pull/22442#discussion_r218545335
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -3611,6 +3611,20 @@ object functions {
*/
def schema_of_json(e:
Github user rxin commented on a diff in the pull request:
https://github.com/apache/spark/pull/22442#discussion_r218250393
--- Diff: sql/core/src/main/scala/org/apache/spark/sql/functions.scala ---
@@ -3611,6 +3611,20 @@ object functions {
*/
def schema_of_json(e:
GitHub user MaxGekk opened a pull request:
https://github.com/apache/spark/pull/22442
[SPARK-25447][SQL] Support JSON options by schema_of_json()
## What changes were proposed in this pull request?
In the PR, I propose to extended the `schema_of_json()` function, and
12 matches
Mail list logo