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)