Package | Description |
---|---|
org.apache.flink.connector.jdbc |
Modifier and Type | Method and Description |
---|---|
static JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder |
JdbcExactlyOnceOptions.builder() |
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder |
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder.withAllowOutOfOrderCommits(boolean allowOutOfOrderCommits)
Set whether transactions may be committed out-of-order in case of retries and this option
is enabled.
|
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder |
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder.withMaxCommitAttempts(int maxCommitAttempts)
Set the number of attempt to commit a transaction (takes effect only if transient failure
happens).
|
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder |
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder.withRecoveredAndRollback(boolean recoveredAndRollback)
Toggle discovery and rollback of prepared transactions upon recovery to prevent new
transactions from being blocked by the older ones.
|
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder |
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder.withTimeoutSec(Optional<Integer> timeoutSec)
Set transaction timeout in seconds (vendor-specific).
|
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder |
JdbcExactlyOnceOptions.JDBCExactlyOnceOptionsBuilder.withTransactionPerConnection(boolean transactionPerConnection)
Set whether the same connection can be used for multiple XA transactions.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.