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