See: Description
Interface | Description |
---|---|
XaFacade |
Facade to the XA operations relevant to
sink . |
XidGenerator |
Xid generator. |
Class | Description |
---|---|
CheckpointAndXid |
A pair of checkpoint id and
Xid representing a checkpoint and an associated pending
(prepared) XA transaction. |
CheckpointAndXidSerializer |
CheckpointAndXid serializer. |
CheckpointAndXidSerializer.CheckpointAndXidSimpleTypeSerializerSnapshot |
SImple
TypeSerializerSnapshot for CheckpointAndXidSerializer . |
JdbcXaSinkFunction<T> |
JDBC sink function that uses XA transactions to provide exactly once guarantees.
|
XaSinkStateSerializer |
XaSinkStateSerializer.
|
XaSinkStateSerializer.XaSinkStateSimpleXaTypeSerializerSnapshot |
Simple
TypeSerializerSnapshot for XaSinkStateSerializer . |
XidSerializer |
Xid serializer. |
XidSerializer.XidSimpleTypeSerializerSnapshot |
Simple
TypeSerializerSnapshot for XidSerializer . |
Exception | Description |
---|---|
XaFacade.EmptyXaTransactionException | |
XaFacade.TransientXaException |
Indicates a transient or unknown failure from the resource manager (see
XA_RBTRANSIENT , XAER_RMFAIL ). |
JdbcXaExactlyOnceSinkFunction
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.