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