如何将数据帧(从 hive 表中获取)写入 hadoop SequenceFile 和 RCFile?

问题描述

我可以把它写成

• ORC

PARQUET

直接和

TEXTFILE

AVRO

使用来自数据块的其他依赖项.

using additional dependencies from databricks.

    <dependency>
        <groupId>com.databricks</groupId>
        <artifactId>spark-csv_2.10</artifactId>
        <version>1.5.0</version>
    </dependency>
    <dependency>
        <groupId>com.databricks</groupId>
        <artifactId>spark-avro_2.10</artifactId>
        <version>2.0.1</version>
    </dependency>

示例代码:

    SparkContext sc = new SparkContext(conf);
    HiveContext hc = new HiveContext(sc);
    DataFrame df = hc.table(hiveTableName);
    df.printSchema();
    DataFrameWriter writer = df.repartition(1).write();

    if ("ORC".equalsIgnoreCase(hdfsFileFormat)) {
        writer.orc(outputHdfsFile);

    } else if ("PARQUET".equalsIgnoreCase(hdfsFileFormat)) {
        writer.parquet(outputHdfsFile);

    } else if ("TEXTFILE".equalsIgnoreCase(hdfsFileFormat)) {
        writer.format("com.databricks.spark.csv").option("header", "true").save(outputHdfsFile);

    } else if ("AVRO".equalsIgnoreCase(hdfsFileFormat)) {
        writer.format("com.databricks.spark.avro").save(outputHdfsFile);
    }

有没有什么办法可以将dataframe写入hadoop SequenceFile和RCFile?

Is there any way to write dataframe into hadoop SequenceFile and RCFile?

推荐答案

您可以使用 void saveAsObjectFile(String path) 将 RDD 保存为序列化对象的 SequenceFile.因此，在您的情况下，您必须从 DataFrame 中检索 RDD:

You can use void saveAsObjectFile(String path) to save a RDD as a SequenceFile of serialized objects. So in your case you have to to retrieve the RDD from the DataFrame:

JavaRDD<Row> rdd = df.javaRDD;
rdd.saveAsObjectFile(outputHdfsFile);

这篇关于如何将数据帧(从 hive 表中获取)写入 hadoop SequenceFile 和 RCFile?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！