TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> |
TwoPhaseCommitSinkFunction.StateSerializer.copy(TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> from) |
TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> |
TwoPhaseCommitSinkFunction.StateSerializer.copy(TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> from,
TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> reuse) |
TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> |
TwoPhaseCommitSinkFunction.StateSerializer.copy(TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> from,
TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> reuse) |
TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> |
TwoPhaseCommitSinkFunction.StateSerializer.deserialize(TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> reuse,
DataInputView source) |
void |
TwoPhaseCommitSinkFunction.StateSerializer.serialize(TwoPhaseCommitSinkFunction.State<TXN,CONTEXT> record,
DataOutputView target) |