org.apache.flink.streaming.api.functions.sink

Class TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>

java.lang.Object

org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>

Enclosing class:

TwoPhaseCommitSinkFunction<IN,TXN,CONTEXT>

@VisibleForTesting
 @Internal
public static final class TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>
extends Object

State POJO class coupling pendingTransaction, context and pendingCommitTransactions.

Field Summary

Fields

Modifier and Type	Field and Description
protected Optional<CONTEXT>	context
protected List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>>	pendingCommitTransactions
protected TwoPhaseCommitSinkFunction.TransactionHolder<TXN>	pendingTransaction

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Optional<CONTEXT>	getContext()
List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>>	getPendingCommitTransactions()
TwoPhaseCommitSinkFunction.TransactionHolder<TXN>	getPendingTransaction()
int	hashCode()
void	setContext(Optional<CONTEXT> context)
void	setPendingCommitTransactions(List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>> pendingCommitTransactions)
void	setPendingTransaction(TwoPhaseCommitSinkFunction.TransactionHolder<TXN> pendingTransaction)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

pendingTransaction

@Nullable
protected TwoPhaseCommitSinkFunction.TransactionHolder<TXN> pendingTransaction

pendingCommitTransactions

protected List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>> pendingCommitTransactions

context

protected Optional<CONTEXT> context

Constructor Detail

State

public State()

State

public State(@Nullable
             TwoPhaseCommitSinkFunction.TransactionHolder<TXN> pendingTransaction,
             List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>> pendingCommitTransactions,
             Optional<CONTEXT> context)

Method Detail

getPendingTransaction

@Nullable
public TwoPhaseCommitSinkFunction.TransactionHolder<TXN> getPendingTransaction()

setPendingTransaction

public void setPendingTransaction(@Nullable
                                  TwoPhaseCommitSinkFunction.TransactionHolder<TXN> pendingTransaction)

getPendingCommitTransactions

public List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>> getPendingCommitTransactions()

setPendingCommitTransactions

public void setPendingCommitTransactions(List<TwoPhaseCommitSinkFunction.TransactionHolder<TXN>> pendingCommitTransactions)

getContext

public Optional<CONTEXT> getContext()

setContext

public void setContext(Optional<CONTEXT> context)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object