Конвертировать фрейм данных pyspark в динамический фрейм - PullRequest
Новая
       21

Конвертировать фрейм данных pyspark в динамический фрейм

0 голосов
/ 24 сентября 2019

У меня есть фрейм данных pyspark.Мне удалось преобразовать динамический фрейм данных в спарк фрейм данных на persons.toDF().Я хочу снова преобразовать фрейм данных spark обратно в динамический фрейм данных в pyspark. Я хотел привести свой столбец к метке времени и снова преобразовать его в динамический фрейм данных для resolChoices.Пожалуйста, помогите мне

1 Ответ

0 голосов
/ 24 сентября 2019

Вы можете создать динамический фрейм из фрейма данных, используя функцию fromDF.

Базовый синтаксис 

dyf = fromDF(dataframe, glue_ctx, name)

, где

  • фрейм данных -Apache Spark SQL DataFrame для преобразования (обязательно).

  • glue_ctx - Объект класса GlueContext, который задает контекст для этого преобразования (обязательно).

  • name - имя результирующего DynamicFrame (обязательно).

Ссылка: Динамический кадр из кадра данных

...