Как преобразовать фрейм данных PySpark Pandas в фрейм данных PySpark? ⇐ Python

[Anonymous]

У меня есть набор данных, хранящийся в pyspark.pandas.frame.DataFrame, который я хочу преобразовать в pyspark.sql.DataFrame, прежде чем сохранять его в дельта-файл. Как это сделать правильно?
PS: Причина в том, что я хочу обеспечить соблюдение схемы при записи при сохранении ее в дельта-файле. Однако метод to_delta PySpark Panda, похоже, не принимает параметры схемы.
Заранее спасибо

Подробнее здесь: https://stackoverflow.com/questions/763 ... -dataframe