diff --git a/python/pyspark/sql/functions/__init__.py b/python/pyspark/sql/functions/__init__.py index b90b5a26ecb01..20d146144400f 100644 --- a/python/pyspark/sql/functions/__init__.py +++ b/python/pyspark/sql/functions/__init__.py @@ -15,6 +15,7 @@ # limitations under the License. # + """PySpark Functions""" from pyspark.sql.functions.builtin import * # noqa: F403 diff --git a/python/pyspark/sql/functions/builtin.py b/python/pyspark/sql/functions/builtin.py index eccb7d768e885..6c2f32ec602f1 100644 --- a/python/pyspark/sql/functions/builtin.py +++ b/python/pyspark/sql/functions/builtin.py @@ -50,6 +50,7 @@ StringType, StructType, NumericType, + MapType _from_numpy_type, ) @@ -21041,10 +21042,11 @@ def json_tuple(col: "ColumnOrName", *fields: str) -> Column: return _invoke_function("json_tuple", _to_java_column(col), _to_seq(sc, fields)) + @_try_remote_functions def from_json( col: "ColumnOrName", - schema: Union[ArrayType, StructType, Column, str], + schema: Union[ArrayType, StructType, Column, str,MapType], options: Optional[Mapping[str, str]] = None, ) -> Column: """