【问题标题】:Which file formats can I save a pyspark dataframe as?我可以将 pyspark 数据框保存为哪些文件格式?
【发布时间】:2018-09-04 13:58:27
【问题描述】:

我想将一个巨大的 pyspark 数据框保存为 Hive 表。我怎样才能有效地做到这一点?我希望使用 pyspark.sql.DataFrameWriter.saveAsTable 中的 saveAsTable(name, format=None, mode=None, partitionBy=None, **options)

# Let's say I have my dataframe, my_df
# Am I able to do the following?
my_df.saveAsTable('my_table')

我的问题是我可以使用哪些格式,我在哪里可以找到自己的信息? OrcSerDe 是一种选择吗?我还在学习这个。谢谢。

【问题讨论】:

  • 你可以考虑压缩,因为你的数据框很大

标签: apache-spark hadoop hive pyspark hiveql


【解决方案1】:

支持以下文件格式。

  • 文字
  • csv
  • ldap
  • json
  • 镶木地板
  • 兽人

参考: https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/DataFrameWriter.scala

【讨论】:

    【解决方案2】:

    所以我能够使用 pyspark.sql.DataFrameWriter 将 pyspark 数据帧写入压缩的 Hive 表。为此,我必须执行以下操作:

    my_df.write.orc('my_file_path')
    

    成功了。

    https://spark.apache.org/docs/1.6.0/api/python/pyspark.sql.html#pyspark.sql.DataFrame.write

    我正在使用 pyspark 1.6.0 顺便说一句

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2018-10-25
      • 2014-04-29
      • 1970-01-01
      • 2018-09-30
      • 2017-07-31
      • 2018-06-04
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多