我已经找到了一个创建动态表的解决方案，但我仍然有一个关于样本大小的问题：

from pyspark.sql.types import IntegerType
#df5 - column with Size of Sample
df5 = df5.withColumn("Size", df5["Size"].cast(IntegerType()))

dataCollect = df5.collect()
df5.show()
for row in dataCollect:
print(row['User'])
print(row['Size'])
#df2 - INPUT with all Records
df6 = df2.filter(df2.User == row['User'])
df6 = df6.limit(row['Sizes'])
df_Final = df_Final.union(df6).distinct()

然后，我创建一个包含所有选定样本的表。