pyspark.sql.functions.to_json

pyspark.sql.functions。 to_json ( 上校:ColumnOrName,選項:可選(Dict(str,str]]=沒有一個 )→pyspark.sql.column.Column

將一個列包含一個StructType,ArrayType或者一個MapType成一個JSON字符串。拋出一個異常,對於一個不支持的類型。

參數
上校 或str

列的名稱包含結構、數組或地圖。

選項 東西,可選

選項來控製轉換。接受JSON數據源相同的選項。看到數據源的選擇在你使用的版本。另外的功能支持漂亮的選擇使漂亮的JSON的一代。

例子

> > >pyspark.sql進口> > >pyspark.sql.types進口*> > >數據=((1,(年齡=2,的名字=“愛麗絲”)))> > >df=火花createDataFrame(數據,(“關鍵”,“價值”))> > >df選擇(to_json(df價值)別名(“json”))收集()行(json = '{“年齡”:2,“名字”:“愛麗絲”}"))> > >數據=((1,((年齡=2,的名字=“愛麗絲”),(年齡=3,的名字=“鮑勃”))))> > >df=火花createDataFrame(數據,(“關鍵”,“價值”))> > >df選擇(to_json(df價值)別名(“json”))收集()行(json = '[{“年齡”:2,“名字”:“愛麗絲”},{“年齡”:3,“名字”:“Bob”}]”))> > >數據=((1,{“名稱”:“愛麗絲”}))> > >df=火花createDataFrame(數據,(“關鍵”,“價值”))> > >df選擇(to_json(df價值)別名(“json”))收集()行(json = '{“名稱”:“愛麗絲”}”))> > >數據=((1,[{“名稱”:“愛麗絲”},{“名稱”:“Bob”})))> > >df=火花createDataFrame(數據,(“關鍵”,“價值”))> > >df選擇(to_json(df價值)別名(“json”))收集()行(json = '[{“名稱”:“愛麗絲”},{“名稱”:“Bob”}]”))> > >數據=((1,(“愛麗絲”,“Bob”)))> > >df=火花createDataFrame(數據,(“關鍵”,“價值”))> > >df選擇(to_json(df價值)別名(“json”))收集()行(json = '[“愛麗絲”、“Bob”]”))