|
Change Parameter Type pulsarRecord : PulsarRecord to recordContext : RecordContext in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext RecordContext) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkProcessor |
From |
To |
|
Change Parameter Type pulsarRecord : PulsarRecord to recordContext : RecordContext in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext RecordContext) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkEffectivelyOnceProcessor |
From |
To |
|
Change Parameter Type pulsarRecord : PulsarRecord to recordContext : RecordContext in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext RecordContext) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkAtMostOnceProcessor |
From |
To |
|
Change Parameter Type pulsarRecord : PulsarRecord to recordContext : RecordContext in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext RecordContext) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkAtLeastOnceProcessor |
From |
To |
|
Rename Parameter srcTopicName : String to srcPartitionId : String in method public getProducer(srcPartitionId String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Rename Parameter pulsarRecord : PulsarRecord to recordContext : RecordContext in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext RecordContext) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkAtLeastOnceProcessor |
From |
To |
|
Rename Parameter pulsarRecord : PulsarRecord to recordContext : RecordContext in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext RecordContext) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkEffectivelyOnceProcessor |
From |
To |
|
Rename Parameter srcTopicPartition : String to srcPartitionId : String in method public getProducer(srcPartitionId String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Rename Parameter srcTopicName : String to srcPartitionId : String in method public closeProducer(srcPartitionId String) : void in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Rename Parameter pulsarRecord : PulsarRecord to recordContext : RecordContext in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext RecordContext) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkProcessor |
From |
To |
|
Rename Parameter srcTopicName : String to srcPartitionId : String in method public getProducer(srcPartitionId String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.Producers |
From |
To |
|
Rename Parameter srcTopicName : String to srcPartitionId : String in method public closeProducer(srcPartitionId String) : void in class org.apache.pulsar.functions.instance.producers.Producers |
From |
To |
|
Rename Parameter pulsarRecord : PulsarRecord to recordContext : RecordContext in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext RecordContext) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkAtMostOnceProcessor |
From |
To |