diff options
| author | hyukjinkwon <gurwls223@gmail.com> | 2016-07-06 10:45:51 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-07-06 10:45:51 -0700 |
| commit | 4e14199ff740ea186eb2cec2e5cf901b58c5f90e (patch) | |
| tree | cfd7850c821e764c2243615a8fd8642d73323da1 /python/pyspark/sql/functions.py | |
| parent | b1310425b30cbd711e4834d65a0accb3c5a8403a (diff) | |
| download | spark-4e14199ff740ea186eb2cec2e5cf901b58c5f90e.tar.gz spark-4e14199ff740ea186eb2cec2e5cf901b58c5f90e.tar.bz2 spark-4e14199ff740ea186eb2cec2e5cf901b58c5f90e.zip | |
[MINOR][PYSPARK][DOC] Fix wrongly formatted examples in PySpark documentation
## What changes were proposed in this pull request?
This PR fixes wrongly formatted examples in PySpark documentation as below:
- **`SparkSession`**
- **Before**
- **After**
- **`Builder`**
- **Before**
- **After**
This PR also fixes several similar instances across the documentation in `sql` PySpark module.
## How was this patch tested?
N/A
Author: hyukjinkwon <gurwls223@gmail.com>
Closes #14063 from HyukjinKwon/minor-pyspark-builder.
Diffstat (limited to 'python/pyspark/sql/functions.py')
| -rw-r--r-- | python/pyspark/sql/functions.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/python/pyspark/sql/functions.py b/python/pyspark/sql/functions.py index 7a7345170c..92d709ee40 100644 --- a/python/pyspark/sql/functions.py +++ b/python/pyspark/sql/functions.py @@ -1550,8 +1550,8 @@ def translate(srcCol, matching, replace): The translate will happen when any character in the string matching with the character in the `matching`. - >>> spark.createDataFrame([('translate',)], ['a']).select(translate('a', "rnlt", "123")\ - .alias('r')).collect() + >>> spark.createDataFrame([('translate',)], ['a']).select(translate('a', "rnlt", "123") \\ + ... .alias('r')).collect() [Row(r=u'1a2s3ae')] """ sc = SparkContext._active_spark_context @@ -1670,8 +1670,8 @@ def get_json_object(col, path): >>> data = [("1", '''{"f1": "value1", "f2": "value2"}'''), ("2", '''{"f1": "value12"}''')] >>> df = spark.createDataFrame(data, ("key", "jstring")) - >>> df.select(df.key, get_json_object(df.jstring, '$.f1').alias("c0"), \ - get_json_object(df.jstring, '$.f2').alias("c1") ).collect() + >>> df.select(df.key, get_json_object(df.jstring, '$.f1').alias("c0"), \\ + ... get_json_object(df.jstring, '$.f2').alias("c1") ).collect() [Row(key=u'1', c0=u'value1', c1=u'value2'), Row(key=u'2', c0=u'value12', c1=None)] """ sc = SparkContext._active_spark_context |