pyspark.sql.functions.get_json_object

pyspark.sql.functions。 get_json_object ( 上校:ColumnOrName,路徑:str )→pyspark.sql.column.Column

從一個json字符串提取json對象指定基於json的路徑,並返回的json字符串提取的json對象。它將返回null如果輸入json字符串是無效的。

參數

上校 列或str

字符串列以json格式

路徑 str

道路提取的json對象

例子

> > >數據=((“1”,“‘{“f1”:“value1”,“f2”:“value2”}”),(“2”,“‘{“f1”:“value12”}”)]> > >df=火花。createDataFrame(數據,(“關鍵”,“jstring”))> > >df。選擇(df。關鍵,get_json_object(df。jstring,“.f1美元”)。別名(“c0”),\…get_json_object(df。jstring,“.f2美元”)。別名(“c1”))。收集()行(關鍵= ' 1 ',c0 = value1, c1 = value2)、行(關鍵= ' 2 ',c0 = value12, c1 = None))

以前的

pyspark.sql.functions.posexplode_outer

下一個

pyspark.sql.functions.json_tuple