Uses of Class
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.KafkaTransactionContext

Packages that use FlinkKafkaProducer011.KafkaTransactionContext

Package	Description
org.apache.flink.streaming.connectors.kafka

Uses of FlinkKafkaProducer011.KafkaTransactionContext in org.apache.flink.streaming.connectors.kafka

Methods in org.apache.flink.streaming.connectors.kafka that return FlinkKafkaProducer011.KafkaTransactionContext

Modifier and Type	Method and Description
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.copy(FlinkKafkaProducer011.KafkaTransactionContext from)
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.copy(FlinkKafkaProducer011.KafkaTransactionContext from, FlinkKafkaProducer011.KafkaTransactionContext reuse)
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.createInstance()
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.deserialize(DataInputView source)
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.deserialize(FlinkKafkaProducer011.KafkaTransactionContext reuse, DataInputView source)

Methods in org.apache.flink.streaming.connectors.kafka that return types with arguments of type FlinkKafkaProducer011.KafkaTransactionContext

Modifier and Type	Method and Description
protected Optional<FlinkKafkaProducer011.KafkaTransactionContext>	FlinkKafkaProducer011.initializeUserContext()

Methods in org.apache.flink.streaming.connectors.kafka with parameters of type FlinkKafkaProducer011.KafkaTransactionContext

Modifier and Type	Method and Description
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.copy(FlinkKafkaProducer011.KafkaTransactionContext from)
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.copy(FlinkKafkaProducer011.KafkaTransactionContext from, FlinkKafkaProducer011.KafkaTransactionContext reuse)
FlinkKafkaProducer011.KafkaTransactionContext	FlinkKafkaProducer011.ContextStateSerializer.deserialize(FlinkKafkaProducer011.KafkaTransactionContext reuse, DataInputView source)
void	FlinkKafkaProducer011.ContextStateSerializer.serialize(FlinkKafkaProducer011.KafkaTransactionContext record, DataOutputView target)