b283ebd3e51aa86f6b9f0a6607f430996f0032f7
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 11
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute hasMessageAvailable : boolean to previousOldAssignmentMsgId : MessageId in method public accept(msg Message<byte[]>) : void in class org.apache.pulsar.functions.worker.FunctionAssignmentTailer | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type hasMessageAvailable : boolean to previousOldAssignmentMsgId : MessageId in method public accept(msg Message<byte[]>) : void in class org.apache.pulsar.functions.worker.FunctionAssignmentTailer | From | To | |
| Extract Method | 3 | ||
| Extract Method private createNamespace(admin PulsarAdmin, cluster String, namespace String, infiniteRetention boolean) : void extracted from private initialize(workerConfig WorkerConfig) : URI in class org.apache.pulsar.functions.worker.Worker | From | To | |
| Extract Method private hasMessageAvailable() : boolean extracted from public accept(msg Message<byte[]>) : void in class org.apache.pulsar.functions.worker.FunctionAssignmentTailer | From | To | |
| Extract Method private publishAssignmentUpdate(assignmentVersion long, assignments List<Assignment>) : void extracted from private invokeScheduler() : void in class org.apache.pulsar.functions.worker.SchedulerManager | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public processAssignmentUpdate(messageId MessageId, assignmentsUpdates List<AssignmentsUpdate>) : void extracted from public accept(msg Message<byte[]>) : void in class org.apache.pulsar.functions.worker.FunctionAssignmentTailer & moved to class org.apache.pulsar.functions.worker.FunctionRuntimeManager | From | To |