pyspark.sql.functions.sequence¶
-
pyspark.sql.functions。序列( 開始:ColumnOrName,停止:ColumnOrName,一步:可選(ColumnOrName]=沒有一個 )→pyspark.sql.column.Column¶ -
生成一個整數序列開始來停止遞增的一步。如果一步沒有設置,遞增1如果開始小於或等於什麼停止,否則1。
例子
> > >df1=火花。createDataFrame(((- - - - - -2,2)),(“C1”,C2的))> > >df1。選擇(序列(“C1”,C2的)。別名(“r”))。收集()行(r = (2, 1, 0, 1, 2)))> > >df2=火花。createDataFrame(((4,- - - - - -4,- - - - - -2)),(“C1”,C2的,“C3”))> > >df2。選擇(序列(“C1”,C2的,“C3”)。別名(“r”))。收集()行(r = [4 2 0、2、4)))