Мне нужно определить типы столбцов в пределах spark.createDataFrame()
. Например, мне нужно определить формат столбцов Возраст и Вес, и я использую следующий код:
from pyspark.sql.types import IntegerType, FloaType
Age1 = Spark.createDataFrame(df['Age'], IntegerType ())
Weight1 = Spark.createDataFrame(df['Weight'], FloatType ())
Как я могу сделать это внутри одного spark.createDataFrame
вместо создания двух?