You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "Sagar Sumit (Jira)" <ji...@apache.org> on 2022/05/26 05:10:00 UTC

[jira] [Closed] (HUDI-4040) Add customerColumnPartitionerRow support

     [ https://issues.apache.org/jira/browse/HUDI-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Sagar Sumit closed HUDI-4040.
-----------------------------
    Resolution: Done

> Add customerColumnPartitionerRow support
> ----------------------------------------
>
>                 Key: HUDI-4040
>                 URL: https://issues.apache.org/jira/browse/HUDI-4040
>             Project: Apache Hudi
>          Issue Type: Improvement
>            Reporter: Hui An
>            Priority: Major
>              Labels: pull-request-available
>
> like RDDCustomColumnsSortPartitioner, we can use this partitioner to sort customer columns users specified.
> for example:
> {code:scala}
> df.write.format("hudi")
> .option(HoodieWriteConfig.TABLE_NAME, "test_table")
> .option(OPERATION.key, DataSourceWriteOptions.BULK_INSERT_OPERATION_OPT_VAL)
> .option(RECORDKEY_FIELD.key, "session_id")
> .option(PARTITIONPATH_FIELD.key, "date")
> .option("hoodie.bulkinsert.user.defined.partitioner.class", "org.apache.hudi.execution.bulkinsert.CustomColumnsSortPartitionerWithRows")
> .option("hoodie.bulkinsert.user.defined.partitioner.sort.columns", "page_type")
> .mode(SaveMode.Append)
> .save("hdfs://test/test_table")
> {code}



--
This message was sent by Atlassian Jira
(v8.20.7#820007)