d0c231ebf866ee25e08c43743b254035b4e18c80
Files Diff
- Added: 0
- Removed: 5
- Renamed: 0
- Modified: 7
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Rename Method | 2 | ||
| Move And Rename Method public handleResult(container FunctionContainer, result ExecutionResult, stats FunctionStatsImpl, processAt long) : boolean from class org.apache.pulsar.functions.runtime.subscribermanager.ResultsProcessor to private processResult(msg Message, result ExecutionResult, processAt long) : void from class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer | From | To | |
| Move And Rename Method private createProducer(topicName String) : void from class org.apache.pulsar.functions.runtime.subscribermanager.ProducerManager to private startSinkProducer() : void from class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer | From | To | |
| Move Method | 1 | ||
| Move Method private convertMessageIdToString(messageId MessageId) : String from class org.apache.pulsar.functions.runtime.subscribermanager.TopicSubscription to private convertMessageIdToString(messageId MessageId) : String from class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer | From | To | |
| Change Return Type | 1 | ||
| Change Return Type boolean to void in method private processResult(msg Message, result ExecutionResult, processAt long) : void in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer | From | To | |
| Extract Method | 1 | ||
| Extract Method private startFunctionThread() : void extracted from public start() : void in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type queue : LinkedBlockingQueue<Payload> to queue : LinkedBlockingQueue<Message> in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer | From | To | |
| Change Attribute Type threadFunctionContainerFactory : ThreadFunctionContainerFactory to threadFunctionContainerFactory : FunctionContainerFactory in class org.apache.pulsar.functions.runtime.spawner.Spawner | From | To |