StructType¶

類 pyspark.sql.types。 StructType ( 字段:可選(列表(pyspark.sql.types.StructField]]=沒有一個 ) ¶

結構體類型的列表組成StructField。

這是代表一個數據類型行。

一個迭代StructType將遍曆StructField年代,包含StructField可以訪問其名稱或位置。

例子

           > > >struct1=StructType([StructField(“f1”,StringType(),真正的)))> > >struct1(“f1”]StructField (f1, StringType(),真的)> > >struct1(0]StructField (f1, StringType(),真的)
          

           > > >struct1=StructType([StructField(“f1”,StringType(),真正的)))> > >struct2=StructType([StructField(“f1”,StringType(),真正的)))> > >struct1= =struct2真正的> > >struct1=StructType([StructField(“f1”,CharType(10),真正的)))> > >struct2=StructType([StructField(“f1”,CharType(10),真正的)))> > >struct1= =struct2真正的> > >struct1=StructType([StructField(“f1”,VarcharType(10),真正的)))> > >struct2=StructType([StructField(“f1”,VarcharType(10),真正的)))> > >struct1= =struct2真正的> > >struct1=StructType([StructField(“f1”,StringType(),真正的)))> > >struct2=StructType([StructField(“f1”,StringType(),真正的),…StructField(“f2”,IntegerType(),假)))> > >struct1= =struct2假
          

方法

`添加`(字段(data_type nullable,元數據))	構造一個`StructType`通過添加新的元素,定義模式。
`字段名`()	返回列表中的所有字段名稱。
`fromInternal`(obj)	將內部SQL對象轉換成一個本機Python對象。
`fromJson`(json)
`json`()
`jsonValue`()
`needConversion`()	這類型之間的轉換需要Python對象和內部SQL對象。
`simpleString`()
`toInternal`(obj)	Python對象轉換成一個內部SQL對象。
`typeName`()

方法的文檔

添加 ( 場:聯盟(str,pyspark.sql.types.StructField],data_type:聯盟(str, pyspark.sql.types。數據類型,沒有)=沒有一個,可以為空:bool=真正的,元數據:可選(Dict(str,任何]]=沒有一個 )→pyspark.sql.types.StructType ¶

構造一個StructType通過添加新的元素,定義模式。該方法接受:

一個參數是一個StructField對象。

2和4之間的參數(名稱、data_type nullable(可選),元數據(可選)。data_type參數可以是一個字符串或一個數據類型對象。

參數

場 str或StructField: 字段的名稱或一個StructField對象
data_type 數據類型、可選: 如果存在的數據類型StructField創建
可以為空 bool,可選: 字段添加是否應該nullable(默認正確)
元數據 東西,可選: 任何額外的元數據(默認沒有)

返回

StructType

例子

             > > >struct1=StructType()。添加(“f1”,StringType(),真正的)。添加(“f2”,StringType(),真正的,沒有一個)> > >struct2=StructType([StructField(“f1”,StringType(),真正的),\…StructField(“f2”,StringType(),真正的,沒有一個)))> > >struct1= =struct2真正的> > >struct1=StructType()。添加(StructField(“f1”,StringType(),真正的))> > >struct2=StructType([StructField(“f1”,StringType(),真正的)))> > >struct1= =struct2真正的> > >struct1=StructType()。添加(“f1”,“字符串”,真正的)> > >struct2=StructType([StructField(“f1”,StringType(),真正的)))> > >struct1= =struct2真正的
            

字段名 ( )→列表(str] ¶

返回列表中的所有字段名稱。

例子

             > > >結構體=StructType([StructField(“f1”,StringType(),真正的)))> > >結構體。字段名()(“f1”)
            

fromInternal ( obj:元組 )→pyspark.sql.types.Row¶: 將內部SQL對象轉換成一個本機Python對象。

classmethod fromJson ( json:Dict(str,任何] )→pyspark.sql.types.StructType ¶

json ( )→str¶

jsonValue ( )→Dict類型(str,任何] ¶

needConversion ( )→bool¶

這類型之間的轉換需要Python對象和內部SQL對象。

這是用來避免不必要的轉換ArrayType / MapType / StructType。

simpleString ( )→str¶

toInternal ( obj:元組 )→元組¶: Python對象轉換成一個內部SQL對象。

classmethod typeName ( )→str¶

以前的

StructField

下一個

TimestampType