在sparkDataframe的一列中有4个值-
colA Read Join Sort Write
输出是基于列值创建4个python变量，如-
v1=Read v2=Join v3=Sort v4=Write
如果列中有3个值，则需要输出3个变量。谢谢
o8x7eapl1#
您可以收集字典中的数据，并在需要时将字典值用作变量
vars = {i:v.colA for i,v in enumerate(df.collect())}
现在要访问数据，只需使用类似于
print(vars[0]) [Out] : Read
1条答案
按热度按时间o8x7eapl1#
您可以收集字典中的数据，并在需要时将字典值用作变量
现在要访问数据，只需使用类似于