8a99e50ff7a5f9ac1a6f602e392340a9c4be497d
Files Diff
- Added: 11
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Attribute | 1 | ||
| Extract Attribute private running : boolean in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable | From | To | |
| Extract Method | 4 | ||
| Extract Method private ackMessage(msg InputMessage) : void extracted from private processResult(msg InputMessage, result JavaExecutionResult, startTime long, endTime long) : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable | From | To | |
| Extract Method private sendOutputMessage(srcMsg InputMessage, result JavaExecutionResult, output byte[]) : void extracted from private processResult(msg InputMessage, result JavaExecutionResult, startTime long, endTime long) : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable | From | To | |
| Extract Method package setupJavaInstance() : JavaInstance extracted from public run() : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable | From | To | |
| Extract Method private getSubscriptionType() : SubscriptionType extracted from private createConsumerConfiguration(topicName String) : ConsumerConfiguration in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type sinkProducer : Producer to sinkProducer : Producers in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable | From | To | |
| Change Attribute Type queue : LinkedBlockingQueue<InputMessage> to queue : LinkedBlockingDeque<InputMessage> in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter msg : InputMessage to srcMsg : InputMessage in method private sendOutputMessage(srcMsg InputMessage, result JavaExecutionResult, output byte[]) : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable | From | To |