我需要帮助如何调用TeamCt和SeniorCt函数,并获得两个总值到def主函数使用Python Pyspark.
def Main(source1):
def TeamCt(source1):
north_total = source1
.filter(F.col(‘team’) == ‘North’)
.groupBy(F.col(‘team’))
.agg(F.count(‘*’).alias(‘n_total’)
return north_total
def SeniorCt(source1):
senior_total = source1
.filter(F.col(‘grade’) == ‘Senior’)
.groupBy(F.col(‘grade’))
.agg(F.count(‘*’).alias(‘s_total’)
return senior_total
1条答案
按热度按时间fcwjkofz1#
希望这能奏效: