Uses of Class
org.apache.flink.streaming.api.functions.sink.legacy.TwoPhaseCommitSinkFunction.TransactionHolder

Packages that use TwoPhaseCommitSinkFunction.TransactionHolder

Package	Description
org.apache.flink.streaming.api.functions.sink.legacy

Uses of TwoPhaseCommitSinkFunction.TransactionHolder in org.apache.flink.streaming.api.functions.sink.legacy

Fields in org.apache.flink.streaming.api.functions.sink.legacy declared as TwoPhaseCommitSinkFunction.TransactionHolder

Modifier and Type	Field	Description
protected TwoPhaseCommitSinkFunction.TransactionHolder<TXN>	TwoPhaseCommitSinkFunction.State.pendingTransaction

Fields in org.apache.flink.streaming.api.functions.sink.legacy with type parameters of type TwoPhaseCommitSinkFunction.TransactionHolder

Modifier and Type	Field	Description
protected LinkedHashMap<Long,TwoPhaseCommitSinkFunction.TransactionHolder<TXN>>	TwoPhaseCommitSinkFunction.pendingCommitTransactions	Deprecated.
protected List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>>	TwoPhaseCommitSinkFunction.State.pendingCommitTransactions

Methods in org.apache.flink.streaming.api.functions.sink.legacy that return TwoPhaseCommitSinkFunction.TransactionHolder

Modifier and Type	Method	Description
TwoPhaseCommitSinkFunction.TransactionHolder<TXN>	TwoPhaseCommitSinkFunction.State.getPendingTransaction()

Methods in org.apache.flink.streaming.api.functions.sink.legacy that return types with arguments of type TwoPhaseCommitSinkFunction.TransactionHolder

Modifier and Type	Method	Description
List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>>	TwoPhaseCommitSinkFunction.State.getPendingCommitTransactions()

Methods in org.apache.flink.streaming.api.functions.sink.legacy with parameters of type TwoPhaseCommitSinkFunction.TransactionHolder

Modifier and Type	Method	Description
void	TwoPhaseCommitSinkFunction.State.setPendingTransaction(TwoPhaseCommitSinkFunction.TransactionHolder<TXN> pendingTransaction)

Method parameters in org.apache.flink.streaming.api.functions.sink.legacy with type arguments of type TwoPhaseCommitSinkFunction.TransactionHolder

Modifier and Type	Method	Description
void	TwoPhaseCommitSinkFunction.State.setPendingCommitTransactions(List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>> pendingCommitTransactions)

Constructors in org.apache.flink.streaming.api.functions.sink.legacy with parameters of type TwoPhaseCommitSinkFunction.TransactionHolder

Constructor	Description
State(TwoPhaseCommitSinkFunction.TransactionHolder<TXN> pendingTransaction, List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>> pendingCommitTransactions, Optional<CONTEXT> context)

Constructor parameters in org.apache.flink.streaming.api.functions.sink.legacy with type arguments of type TwoPhaseCommitSinkFunction.TransactionHolder

Constructor	Description
State(TwoPhaseCommitSinkFunction.TransactionHolder<TXN> pendingTransaction, List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>> pendingCommitTransactions, Optional<CONTEXT> context)