Package | Description |
---|---|
org.apache.flink.connector.jdbc.xa |
Provides exactly-once JDBC sink implementation using Java XA transactions API (JTA).
|
Modifier and Type | Method and Description |
---|---|
void |
XaFacade.commit(Xid xid,
boolean ignoreUnknown)
Commit previously prepared transaction.
|
void |
XaFacade.failAndRollback(Xid xid)
End transaction as
failed ; in case of error,
try to roll it back. |
Collection<Xid> |
XaFacade.recover()
Note: this can block on some non-MVCC databases if there are ended not prepared transactions.
|
void |
XaFacade.rollback(Xid xid)
Rollback previously prepared transaction.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.