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

Class Summary

Class	Description
DiscardingSink<T>	Deprecated. This interface will be removed in future versions.
TwoPhaseCommitSinkFunction<IN,TXN,CONTEXT>	Deprecated. This interface will be removed in future versions.
TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>	State POJO class coupling pendingTransaction, context and pendingCommitTransactions.
TwoPhaseCommitSinkFunction.StateSerializer<TXN,CONTEXT>	Custom TypeSerializer for the sink state.
TwoPhaseCommitSinkFunction.StateSerializerSnapshot<TXN,CONTEXT>	Snapshot for the TwoPhaseCommitSinkFunction.StateSerializer.
TwoPhaseCommitSinkFunction.TransactionHolder<TXN>	Adds metadata (currently only the start time of the transaction) to the transaction object.