-
-
Save yogenderPalChandra/f2aa61798bca34745434e5c3d298c3b3 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
def rdd_df_2_pd_df(rdd_df): | |
""" changes the name of rdd rows to more identifiable name - cost | |
returns pandas df | |
""" | |
row = Row("cost") | |
match_df_flat1_df= rdd_df.map(row).toDF() | |
return match_df_flat1_df.toPandas() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment