protected void |
FlinkKafkaProducer.abort(FlinkKafkaProducer.KafkaTransactionState transaction) |
protected void |
FlinkKafkaProducer.commit(FlinkKafkaProducer.KafkaTransactionState transaction) |
FlinkKafkaProducer.KafkaTransactionState |
FlinkKafkaProducer.TransactionStateSerializer.copy(FlinkKafkaProducer.KafkaTransactionState from) |
FlinkKafkaProducer.KafkaTransactionState |
FlinkKafkaProducer.TransactionStateSerializer.copy(FlinkKafkaProducer.KafkaTransactionState from,
FlinkKafkaProducer.KafkaTransactionState reuse) |
FlinkKafkaProducer.KafkaTransactionState |
FlinkKafkaProducer.TransactionStateSerializer.deserialize(FlinkKafkaProducer.KafkaTransactionState reuse,
DataInputView source) |
void |
FlinkKafkaProducer.invoke(FlinkKafkaProducer.KafkaTransactionState transaction,
IN next,
SinkFunction.Context context) |
protected void |
FlinkKafkaProducer.preCommit(FlinkKafkaProducer.KafkaTransactionState transaction) |
protected void |
FlinkKafkaProducer.recoverAndAbort(FlinkKafkaProducer.KafkaTransactionState transaction) |
protected void |
FlinkKafkaProducer.recoverAndCommit(FlinkKafkaProducer.KafkaTransactionState transaction) |
void |
FlinkKafkaProducer.TransactionStateSerializer.serialize(FlinkKafkaProducer.KafkaTransactionState record,
DataOutputView target) |