pyspark里转成整数型报错TypeError: unexpected type:

  算法/数据结构/数据库 sql    浏览次数:1018        分享
0

pyspark里转成整数型报错TypeError: unexpected type: <class 'type'>

df.withColumn('flag', F.col('logintype').isin(['sec', 'fta']).cast(IntegerType))

在df中插入一列,因为是逻辑是否的类型,所以想转成Intergtype整数型,但是程序报错

TypeError: unexpected type:  <class 'type'>

这个该怎么处理

 

ziyu   2020-07-08 21:59



   1个回答 
2


from pyspark.sql.types import  IntegerType

df.withColumn('flag', F.col('logintype').isin(['sec', 'fta']).cast(IntegerType()))


SofaSofa数据科学社区DS面试题库 DS面经

泥鳅   2020-07-10 23:46



  相关主题

pyspark里怎么把类似‘yyyy-mm-dd‘的字符串转成星期几的形式?   1回答

怎么用pyspark取出hive表里的json串中某一个key的值?   1回答

pyspark获取当月的最后一天的日期?   1回答

pyspark返回每个分组某个值最大的行   1回答

pyspark里怎么查看一个dataframe的schema?   1回答

pyspark里怎么求百分位数?   1回答

spark里怎么refresh表?   3回答

spark sql里怎么用case when?   1回答

怎么将两个pyspark dataframe以串联的形式合并?   1回答

返回pyspark dataframe的行数?   1回答

SparkML里线性回归底层是什么原理?   1回答

pyspark dataframe的collect()方法是什么意思?   2回答



回答问题时需要注意什么?

我们谢绝在回答前讲“生动”的故事。

我们谢绝“这么简单,你自己想”、“书上有的,你认真看”这类的回答;如果你认为对方的提问方式或者内容不妥,你可以直接忽略该问题,不用进行任何作答,甚至可以对该问题投反对票。

我们谢绝答非所问。

我们谢绝自己不会、硬要回答。

我们感激每一个用户在编写答案时的努力与付出!