Код: Выделить всё
import pyspark.sql.functions as F
def df_kyc (JOHNNY):
JOHNNY = JOHNNY.select(*[
F.col(c).cast("string").alias(c) if t == "timestamp" else F.col(c)
for c, t in JOHNNY.dtypes])
JOHNNY = JOHNNY.toPandas()
return JOHNNY
"
/opt/spark/work-dir/< Strong>environment/lib/python3.8/site-packages/pyspark/sql/dataframe.py:148: Предупреждение пользователя: конструктор DataFrame является внутренним. Не используйте его напрямую.
/>warnings.warn("Конструктор DataFrame является внутренним. Не используйте его напрямую.")
"
Знаете, пожалуйста, что с этим не так? Спасибо
Подробнее здесь: https://stackoverflow.com/questions/792 ... t-in-found
Мобильная версия