e30808c1ff6bf5c012b22c82ca72eec0c19d5b8b
Files Diff
- Added: 9
- Removed: 1
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Push Down Method | 1 | ||
| Push Down Method public reset() : void from class org.apache.pulsar.functions.instance.JavaInstance.ExecutionResult to public reset() : void from class org.apache.pulsar.functions.instance.JavaExecutionResult | From | To | |
| Extract Subclass | 1 | ||
| Extract Subclass org.apache.pulsar.functions.instance.JavaExecutionResult from class org.apache.pulsar.functions.instance.JavaInstance.ExecutionResult | From | To | |
| Rename Variable | 3 | ||
| Rename Variable byteIn : ByteArrayInputStream to bis : ByteArrayInputStream in method private deserialize(data byte[]) : Object in class org.apache.pulsar.functions.instance.JavaInstance | From | To | |
| Rename Variable inputStream : ByteArrayInputStream to out : ObjectOutput in method private serialize(resultValue Object) : byte[] in class org.apache.pulsar.functions.instance.JavaInstance | From | To | |
| Rename Variable in : ObjectInputStream to ois : ObjectInputStream in method private deserialize(data byte[]) : Object in class org.apache.pulsar.functions.instance.JavaInstance | From | To | |
| Change Return Type | 1 | ||
| Change Return Type ExecutionResult to JavaExecutionResult in method public handleMessage(messageId String, topicName String, data byte[]) : JavaExecutionResult in class org.apache.pulsar.functions.instance.JavaInstance | From | To | |
| Push Down Attribute | 2 | ||
| Push Down Attribute private timeoutException : TimeoutException from class org.apache.pulsar.functions.instance.JavaInstance.ExecutionResult to private timeoutException : TimeoutException from class org.apache.pulsar.functions.instance.JavaExecutionResult | From | To | |
| Push Down Attribute private userException : Exception from class org.apache.pulsar.functions.instance.JavaInstance.ExecutionResult to private userException : Exception from class org.apache.pulsar.functions.instance.JavaExecutionResult | From | To | |
| Move Attribute | 3 | ||
| Move Attribute protected fnCache : FunctionCacheManager from class org.apache.pulsar.functions.runtime.container.AbstractFunctionContainerFactory to protected fnCache : FunctionCacheManager from class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainerFactory | From | To | |
| Move Attribute private userName : String from class org.apache.pulsar.functions.instance.JavaInstanceConfig to private userName : String from class org.apache.pulsar.functions.fs.FunctionConfig | From | To | |
| Move Attribute private nameSpace : String from class org.apache.pulsar.functions.instance.JavaInstanceConfig to private nameSpace : String from class org.apache.pulsar.functions.fs.FunctionConfig | From | To | |
| Move And Rename Class | 2 | ||
| Move And Rename Class org.apache.pulsar.functions.instance.JavaInstance.ExecutionResult moved and renamed to org.apache.pulsar.functions.instance.JavaExecutionResult | From | To | |
| Move And Rename Class org.apache.pulsar.functions.instance.JavaInstance.ExecutionResult moved and renamed to org.apache.pulsar.functions.spawner.ExecutionResult | From | To | |
| Rename Attribute | 3 | ||
| Rename Attribute instanceConfig : JavaInstanceConfig to javaInstanceConfig : JavaInstanceConfig in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer | From | To | |
| Rename Attribute topicName : String to currentTopicName : String in class org.apache.pulsar.functions.instance.ContextImpl | From | To | |
| Rename Attribute logger : Logger to log : Logger in class org.apache.pulsar.functions.instance.JavaInstance | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type result : JavaInstance.ExecutionResult to result : ExecutionResult in method public testLongRunningFunction() : void in class org.apache.pulsar.functions.instance.JavaInstanceTest | From | To | |
| Change Variable Type inputStream : ByteArrayInputStream to out : ObjectOutput in method private serialize(resultValue Object) : byte[] in class org.apache.pulsar.functions.instance.JavaInstance | From | To | |
| Change Variable Type result : JavaInstance.ExecutionResult to result : ExecutionResult in method public testLambda() : void in class org.apache.pulsar.functions.instance.JavaInstanceTest | From | To | |
| Extract Method | 1 | ||
| Extract Method private serialize(resultValue Object) : byte[] extracted from public handleMessage(messageId String, topicName String, data byte[]) : ExecutionResult in class org.apache.pulsar.functions.instance.JavaInstance | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type executionResult : ExecutionResult to executionResult : JavaExecutionResult in class org.apache.pulsar.functions.instance.JavaInstance | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter containerThreadGroup : ThreadGroup to threadGroup : ThreadGroup in method package ThreadFunctionContainer(instanceConfig JavaInstanceConfig, fnCache FunctionCacheManager, threadGroup ThreadGroup) in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer | From | To |