pyspark.sql.functions.schema_of_json¶

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

解析JSON字符串並推斷其在DDL格式模式。

參數

json 列或str: 一個JSON字符串或一個可折疊的字符串列包含一個JSON字符串。
選項東西,可選: 選項來控製解析。接受JSON數據源相同的選項。看到數據源的選擇在你使用的版本。

例子

           > > >df=火花。範圍(1)> > >df。選擇(schema_of_json(點燃(“{”“:0}”))。別名(“json”))。收集()行(json = ' STRUCT <答:BIGINT > '))> > >模式=schema_of_json(”{:1}”,{“allowUnquotedFieldNames”:“真正的”})> > >df。選擇(模式。別名(“json”))。收集()行(json = ' STRUCT <答:BIGINT > '))
          

以前的

pyspark.sql.functions.from_json

下一個

pyspark.sql.functions.to_json