pulsar 4cfa83aeeee27e13b258065c19c0fc1488255145

4cfa83aeeee27e13b258065c19c0fc1488255145

Files Diff

Added: 4
Removed: 1
Renamed: 0
Modified: 18

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	8
Change Parameter Type outputMsgBuilder : MessageBuilder<byte[]> to outputMsgBuilder : MessageBuilder in method public sendOutputMessage(srcRecord Record, outputMsgBuilder MessageBuilder) : void in class org.apache.pulsar.functions.instance.processors.MessageProcessor	From	To
Change Parameter Type message : InputMessage to record : Record in method public postReceiveMessage(record Record) : void in class org.apache.pulsar.functions.instance.processors.AtMostOnceProcessor	From	To
Change Parameter Type outputMsgBuilder : MessageBuilder<byte[]> to outputMsgBuilder : MessageBuilder in method public sendOutputMessage(srcRecord Record, outputMsgBuilder MessageBuilder) : void in class org.apache.pulsar.functions.instance.processors.AtMostOnceProcessor	From	To
Change Parameter Type inputMsg : InputMessage to srcRecord : Record in method public sendOutputMessage(srcRecord Record, outputMsgBuilder MessageBuilder) : void in class org.apache.pulsar.functions.instance.processors.AtLeastOnceProcessor	From	To
Change Parameter Type msg : InputMessage to srcRecord : Record in method private processResult(srcRecord Record, result JavaExecutionResult, startTime long, endTime long) : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnable	From	To
Change Parameter Type inputConsumer : Consumer to source : Source in method public JavaInstance(config InstanceConfig, userClassObject Object, clsLoader ClassLoader, pulsarClient PulsarClient, source Source) in class org.apache.pulsar.functions.instance.JavaInstance	From	To
Change Parameter Type outputMsgBuilder : MessageBuilder<byte[]> to outputMsgBuilder : MessageBuilder in method public sendOutputMessage(srcRecord Record, outputMsgBuilder MessageBuilder) : void in class org.apache.pulsar.functions.instance.processors.AtLeastOnceProcessor	From	To
Change Parameter Type outputMsgBuilder : MessageBuilder<byte[]> to outputMsgBuilder : MessageBuilder in method public sendOutputMessage(srcRecord Record, outputMsgBuilder MessageBuilder) : void in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor	From	To
Move Method	2
Move Method private initializeSerDe(serdeClassName String, clsLoader ClassLoader, typeArgs Class<?>[], inputArgs boolean) : SerDe from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to public initializeSerDe(serdeClassName String, clsLoader ClassLoader, type Class<?>) : SerDe from class org.apache.pulsar.functions.instance.InstanceUtils	From	To
Move Method private initializeDefaultSerDe(typeArgs Class<?>[], inputArgs boolean) : SerDe from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to public initializeDefaultSerDe(type Class<?>) : SerDe from class org.apache.pulsar.functions.instance.InstanceUtils	From	To
Change Return Type	2
Change Return Type InputMessage to Record in method public recieveMessage() : Record in class org.apache.pulsar.functions.instance.processors.MessageProcessorBase	From	To
Change Return Type InputMessage to Record in method public recieveMessage() : Record in class org.apache.pulsar.functions.instance.processors.MessageProcessor	From	To
Replace Variable With Attribute	1
Replace Variable With Attribute currentMessage : InputMessage to currentRecord : Record in method public run() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnable	From	To
Change Variable Type	3
Change Variable Type outputMsg : Message<byte[]> to outputMsg : Message in method public sendOutputMessage(srcRecord Record, outputMsgBuilder MessageBuilder) : void in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor	From	To
Change Variable Type producer : Producer<byte[]> to producer : Producer in method public sendOutputMessage(srcRecord Record, outputMsgBuilder MessageBuilder) : void in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor	From	To
Change Variable Type currentMessage : InputMessage to currentRecord : Record in method public run() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnable	From	To
Change Attribute Type	1
Change Attribute Type running : boolean to running : AtomicBoolean in class org.apache.pulsar.functions.instance.JavaInstanceRunnable	From	To
Rename Parameter	4
Rename Parameter message : InputMessage to record : Record in method public postReceiveMessage(record Record) : void in class org.apache.pulsar.functions.instance.processors.AtMostOnceProcessor	From	To
Rename Parameter inputMsg : InputMessage to srcRecord : Record in method public sendOutputMessage(srcRecord Record, outputMsgBuilder MessageBuilder) : void in class org.apache.pulsar.functions.instance.processors.AtLeastOnceProcessor	From	To
Rename Parameter msg : InputMessage to srcRecord : Record in method private processResult(srcRecord Record, result JavaExecutionResult, startTime long, endTime long) : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnable	From	To
Rename Parameter inputConsumer : Consumer to source : Source in method public JavaInstance(config InstanceConfig, userClassObject Object, clsLoader ClassLoader, pulsarClient PulsarClient, source Source) in class org.apache.pulsar.functions.instance.JavaInstance	From	To

4cfa83aeeee27e13b258065c19c0fc1488255145

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: