|
Change Parameter Type reader : Reader to reader : Reader<byte[]> in method public FunctionAssignmentTailer(functionRuntimeManager FunctionRuntimeManager, reader Reader<byte[]>) in class org.apache.pulsar.functions.worker.FunctionAssignmentTailer |
From |
To |
|
Change Parameter Type consumer : Consumer to consumer : Consumer<?> in method public becameActive(consumer Consumer<?>, partitionId int) : void in class org.apache.pulsar.functions.worker.MembershipManager |
From |
To |
|
Change Parameter Type consumer : Consumer to consumer : Consumer<?> in method public becameInactive(consumer Consumer<?>, partitionId int) : void in class org.apache.pulsar.functions.worker.MembershipManager |
From |
To |
|
Change Parameter Type outputMsgBuilder : MessageBuilder to outputMsgBuilder : MessageBuilder<byte[]> in method public sendOutputMessage(inputMsg InputMessage, outputMsgBuilder MessageBuilder<byte[]>) : void in class org.apache.pulsar.functions.instance.processors.AtLeastOnceProcessor |
From |
To |
|
Change Parameter Type reader : Reader to reader : Reader<byte[]> in method public FunctionMetaDataTopicTailer(functionMetaDataManager FunctionMetaDataManager, reader Reader<byte[]>) in class org.apache.pulsar.functions.worker.FunctionMetaDataTopicTailer |
From |
To |
|
Change Parameter Type msg : Message to msg : Message<byte[]> in method public accept(msg Message<byte[]>) : void in class org.apache.pulsar.functions.worker.FunctionAssignmentTailer |
From |
To |
|
Change Parameter Type outputMsgBuilder : MessageBuilder to outputMsgBuilder : MessageBuilder<byte[]> in method public sendOutputMessage(inputMsg InputMessage, outputMsgBuilder MessageBuilder<byte[]>) : void in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor |
From |
To |
|
Change Parameter Type outputMsgBuilder : MessageBuilder to outputMsgBuilder : MessageBuilder<byte[]> in method public sendOutputMessage(inputMsg InputMessage, outputMsgBuilder MessageBuilder<byte[]>) : void in class org.apache.pulsar.functions.instance.processors.MessageProcessor |
From |
To |
|
Change Parameter Type msg : Message to msg : Message<byte[]> in method public processRequest(msg Message<byte[]>) : void in class org.apache.pulsar.functions.worker.FunctionMetaDataTopicTailer |
From |
To |
|
Change Parameter Type msg : Message to msg : Message<byte[]> in method public accept(msg Message<byte[]>) : void in class org.apache.pulsar.functions.worker.FunctionMetaDataTopicTailer |
From |
To |
|
Change Parameter Type outputMsgBuilder : MessageBuilder to outputMsgBuilder : MessageBuilder<byte[]> in method public sendOutputMessage(inputMsg InputMessage, outputMsgBuilder MessageBuilder<byte[]>) : void in class org.apache.pulsar.functions.instance.processors.AtMostOnceProcessor |
From |
To |
|
Change Return Type Consumer to Consumer<byte[]> in method public getInputConsumer() : Consumer<byte[]> in class org.apache.pulsar.functions.instance.processors.MessageProcessor |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method public getProducer(srcTopicName String, srcTopicPartition int) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.Producers |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method public getProducer(srcTopicName String, srcTopicPartition int) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method protected createProducer(topic String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.AbstractOneOuputTopicProducers |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method private createMockProducer(topic String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOutputTopicProducersTest |
From |
To |
|
Change Return Type Consumer to Consumer<?> in method public getConsumer() : Consumer<?> in class org.apache.pulsar.websocket.ReaderHandler |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method public createProducer(client PulsarClient, topic String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.AbstractOneOuputTopicProducers |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method public createProducer(client PulsarClient, topic String, producerName String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.AbstractOneOuputTopicProducers |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method protected createProducer(topic String, producerName String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.AbstractOneOuputTopicProducers |
From |
To |
|
Change Return Type Consumer to Consumer<byte[]> in method public getConsumer() : Consumer<byte[]> in class org.apache.pulsar.websocket.ConsumerHandler |
From |
To |
|
Change Return Type Producer to Producer<byte[]> in method public getProducer() : Producer<byte[]> in class org.apache.pulsar.websocket.ProducerHandler |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<byte[]> in method public getProducer(srcTopicName String, srcTopicPartition int) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Variable Type mockConsumer : Consumer to mockConsumer : Consumer<byte[]> in method public testConsumerEventListener() : void in class org.apache.pulsar.functions.worker.MembershipManagerTest |
From |
To |
|
Change Variable Type conf : ConsumerConfiguration to listener : ConsumerEventListener in method public testConsumerEventListener() : void in class org.apache.pulsar.functions.worker.MembershipManagerTest |
From |
To |
|
Change Variable Type reader : Reader to reader : Reader<byte[]> in method public initialize() : void in class org.apache.pulsar.functions.worker.FunctionMetaDataManager |
From |
To |
|
Change Variable Type producerMap : IntObjectMap<Producer> to producerMap : IntObjectMap<Producer<byte[]>> in method public close() : void in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<byte[]> in method private createMockProducer(topic String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOutputTopicProducersTest |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<byte[]> in method public testGetCloseProducer() : void in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOutputTopicProducersTest |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<byte[]> in method public closeProducer(srcTopicName String, srcTopicPartition int) : void in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Variable Type msg1 : Message to msg1 : Message<?> in method public testChoosePartitionWithKeyWithoutSequenceId() : void in class org.apache.pulsar.functions.instance.FunctionResultRouterTest |
From |
To |
|
Change Variable Type outputMsg : Message to outputMsg : Message<byte[]> in method public sendOutputMessage(inputMsg InputMessage, outputMsgBuilder MessageBuilder<byte[]>) : void in class org.apache.pulsar.functions.instance.processors.AtMostOnceProcessor |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<byte[]> in method public close() : void in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Variable Type builder : MessageBuilder to builder : MessageBuilder<byte[]> in method public onWebSocketText(message String) : void in class org.apache.pulsar.websocket.ProducerHandler |
From |
To |
|
Change Variable Type msg2 : Message to msg2 : Message<?> in method public testChoosePartitionWithKeyWithoutSequenceId() : void in class org.apache.pulsar.functions.instance.FunctionResultRouterTest |
From |
To |
|
Change Variable Type reader : Reader to reader : Reader<byte[]> in method public FunctionRuntimeManager(workerConfig WorkerConfig, pulsarClient PulsarClient, dlogNamespace Namespace, membershipManager MembershipManager) in class org.apache.pulsar.functions.worker.FunctionRuntimeManager |
From |
To |
|
Change Variable Type msg : Message to msg : Message<?> in method public testChoosePartitionWithoutKeySequenceId() : void in class org.apache.pulsar.functions.instance.FunctionResultRouterTest |
From |
To |
|
Change Variable Type readerBuilder : ReaderBuilder to readerBuilder : ReaderBuilder<byte[]> in method public testCheckFailuresSomeUnassigned() : void in class org.apache.pulsar.functions.worker.MembershipManagerTest |
From |
To |
|
Change Variable Type producerMap : IntObjectMap<Producer> to producerMap : IntObjectMap<Producer<byte[]>> in method public closeProducer(srcTopicName String, srcTopicPartition int) : void in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Variable Type msg2 : Message to msg2 : Message<?> in method public testChoosePartitionWithKeySequenceId() : void in class org.apache.pulsar.functions.instance.FunctionResultRouterTest |
From |
To |
|
Change Variable Type mockClient : PulsarClient to mockClient : PulsarClientImpl in method public testConsumerEventListener() : void in class org.apache.pulsar.functions.worker.MembershipManagerTest |
From |
To |
|
Change Variable Type readerBuilder : ReaderBuilder to readerBuilder : ReaderBuilder<byte[]> in method public testCheckFailuresSomeFailures() : void in class org.apache.pulsar.functions.worker.MembershipManagerTest |
From |
To |
|
Change Variable Type outputMsg : Message to outputMsg : Message<byte[]> in method public sendOutputMessage(inputMsg InputMessage, outputMsgBuilder MessageBuilder<byte[]>) : void in class org.apache.pulsar.functions.instance.processors.AtLeastOnceProcessor |
From |
To |
|
Change Variable Type outputMsg : Message to outputMsg : Message<byte[]> in method public sendOutputMessage(inputMsg InputMessage, outputMsgBuilder MessageBuilder<byte[]>) : void in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor |
From |
To |
|
Change Variable Type producerMap : IntObjectMap<Producer> to producerMap : IntObjectMap<Producer<byte[]>> in method public getProducer(srcTopicName String, srcTopicPartition int) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Variable Type msg : Message to msg : Message<?> in method public testChoosePartitionWithoutKeyWithoutSequenceId() : void in class org.apache.pulsar.functions.instance.FunctionResultRouterTest |
From |
To |
|
Change Variable Type msg1 : Message to msg1 : Message<?> in method public testChoosePartitionWithKeySequenceId() : void in class org.apache.pulsar.functions.instance.FunctionResultRouterTest |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<byte[]> in method public sendOutputMessage(inputMsg InputMessage, outputMsgBuilder MessageBuilder<byte[]>) : void in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor |
From |
To |
|
Change Variable Type readerBuilder : ReaderBuilder to readerBuilder : ReaderBuilder<byte[]> in method public testCheckFailuresNoFailures() : void in class org.apache.pulsar.functions.worker.MembershipManagerTest |
From |
To |
|
Change Attribute Type producers : Map<String,IntObjectMap<Producer>> to producers : Map<String,IntObjectMap<Producer<byte[]>>> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Attribute Type producer : Producer to producer : Producer<byte[]> in class org.apache.pulsar.functions.instance.processors.AtMostOnceProcessor |
From |
To |
|
Change Attribute Type mockProducers : Map<String,Producer> to mockProducers : Map<String,Producer<byte[]>> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOutputTopicProducersTest |
From |
To |
|
Change Attribute Type reader : Reader to reader : Reader<byte[]> in class org.apache.pulsar.functions.worker.FunctionAssignmentTailer |
From |
To |
|
Change Attribute Type producer : Producer to producer : Producer<byte[]> in class org.apache.pulsar.functions.worker.SchedulerManager |
From |
To |
|
Change Attribute Type conf : ConsumerConfiguration to subscriptionType : SubscriptionType in class org.apache.pulsar.websocket.ConsumerHandler |
From |
To |
|
Change Attribute Type producer : Producer to producer : Producer<byte[]> in class org.apache.pulsar.functions.instance.processors.AtLeastOnceProcessor |
From |
To |
|
Change Attribute Type reader : Reader to reader : Reader<byte[]> in class org.apache.pulsar.functions.worker.FunctionMetaDataTopicTailer |
From |
To |
|
Change Attribute Type consumer : Consumer to consumer : Consumer<byte[]> in class org.apache.pulsar.functions.worker.MembershipManager |
From |
To |
|
Change Attribute Type inputConsumer : Consumer to inputConsumer : Consumer<byte[]> in class org.apache.pulsar.functions.instance.processors.MessageProcessorBase |
From |
To |