[ https://issues.apache.org/jira/browse/HUDI-6748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sagar Sumit reassigned HUDI-6748: --------------------------------- Assignee: Sagar Sumit > Enhance TransactionManager to support multi-table transaction > ------------------------------------------------------------- > > Key: HUDI-6748 > URL: https://issues.apache.org/jira/browse/HUDI-6748 > Project: Apache Hudi > Issue Type: Task > Reporter: Sagar Sumit > Assignee: Sagar Sumit > Priority: Major > > Transaction Manager should be database timeline-aware and return a > transaction instance when a transaction is started, which can be used with > dataframe writes as below. > {code:java} > val transaction = HoodieTransactionManager.beginTransaction() > // similar to catalog.addTableToTransaction and execute the write. // Then > pass the control to > HoodieTransactionManager.df1.write.format("hudi").withTransaction(transaction).options(opts1).save(basePath1) > // Same as above. If this failed, then rollback and pass the control to > HoodieTransactionManager.// HoodieTransactionManager will rollback all > previous transactions associated with transaction > id.df2.write.format("hudi").withTransaction(transaction).options(opts2).save(basePath2) > > // All success, go ahead and commit or finish rollback (ROLLED_BACK state on > timeline is written in that case)transaction.commit() {code} > -- This message was sent by Atlassian Jira (v8.20.10#820010)