You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "Forward Xu (Jira)" <ji...@apache.org> on 2022/02/25 00:41:00 UTC
[jira] [Resolved] (HUDI-3161) Add Call Produce Command for spark sql
[ https://issues.apache.org/jira/browse/HUDI-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Forward Xu resolved HUDI-3161.
------------------------------
> Add Call Produce Command for spark sql
> --------------------------------------
>
> Key: HUDI-3161
> URL: https://issues.apache.org/jira/browse/HUDI-3161
> Project: Apache Hudi
> Issue Type: New Feature
> Components: spark-sql
> Reporter: Forward Xu
> Assignee: Forward Xu
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 0.11.0
>
> Original Estimate: 8h
> Remaining Estimate: 8h
>
> example
> {code:java}
> // code placeholder
> # Produce1
> call show_commits_metadata(table => 'test_hudi_table');
> commit_time action partition file_id previous_commit num_writes num_inserts num_deletes num_update_writes total_errors total_log_blocks total_corrupt_logblocks total_rollback_blocks total_log_records total_updated_records_compacted total_bytes_written
> 20220109225319449 commit dt=2021-05-03 d0073a12-085d-4f49-83e9-402947e7e90a-0 null 1 1 0 0 0 0 0 0 0 0 435349
> 20220109225311742 commit dt=2021-05-02 b3b32bac-8a44-4c4d-b433-0cb1bf620f23-0 20220109214830592 1 1 0 0 0 0 0 0 0 0 435340
> 20220109225301429 commit dt=2021-05-01 0d7298b3-6b55-4cff-8d7d-b0772358b78a-0 20220109214830592 1 1 0 0 0 0 0 0 0 0 435340
> 20220109214830592 commit dt=2021-05-01 0d7298b3-6b55-4cff-8d7d-b0772358b78a-0 20220109191631015 0 0 1 0 0 0 0 0 0 0 432653
> 20220109214830592 commit dt=2021-05-02 b3b32bac-8a44-4c4d-b433-0cb1bf620f23-0 20220109191648181 0 0 1 0 0 0 0 0 0 0 432653
> 20220109191648181 commit dt=2021-05-02 b3b32bac-8a44-4c4d-b433-0cb1bf620f23-0 null 1 1 0 0 0 0 0 0 0 0 435341
> 20220109191631015 commit dt=2021-05-01 0d7298b3-6b55-4cff-8d7d-b0772358b78a-0 null 1 1 0 0 0 0 0 0 0 0 435341
> Time taken: 0.844 seconds, Fetched 7 row(s)
> # Produce2
> call rollback_to_instant(table => 'test_hudi_table', instant_time => '20220109225319449');
> rollback_result
> true
> Time taken: 5.038 seconds, Fetched 1 row(s)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)