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”]”))

以前的

pyspark.sql.functions.schema_of_json

下一個

pyspark.sql.functions.size