pulsar 4f03548c5ec468ecb7f63a64990bf17639c33c70

4f03548c5ec468ecb7f63a64990bf17639c33c70

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 86

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Rename Method	1
	Rename Method public testclassInJarImplementsIface() : void renamed to public testClassInJarImplementsIface() : void in class org.apache.pulsar.functions.utils.ReflectionsTest	From	To
	Rename Variable	1
	Rename Variable workerAssigments : List<Assignment> to workerAssignments : List<Assignment> in method private findNextWorker(workerIdToAssignment Map<String,List<Assignment>>) : String in class org.apache.pulsar.functions.worker.scheduler.RoundRobinScheduler	From	To
	Extract Method	9
	Extract Method private getExceptionMetricsLabels(ex Throwable, ts long) : String[] extracted from public addUserException(ex Throwable) : void in class org.apache.pulsar.functions.instance.stats.FunctionStatsManager	From	To
	Extract Method private getExceptionMetricsLabels(ex Throwable, ts long) : String[] extracted from public addSystemException(ex Throwable) : void in class org.apache.pulsar.functions.instance.stats.FunctionStatsManager	From	To
	Extract Method private getExceptionMetricsLabels(ex Throwable, ts long) : String[] extracted from public incrSinkExceptions(ex Throwable) : void in class org.apache.pulsar.functions.instance.stats.SinkStatsManager	From	To
	Extract Method private getTopicOptional(topic String) : Optional<String> extracted from public testSinkAndMessageRouting() : void in class org.apache.pulsar.functions.sink.PulsarSinkTest	From	To
	Extract Method private getExceptionMetricsLabels(ex Throwable, ts long) : String[] extracted from public incrSysExceptions(ex Throwable) : void in class org.apache.pulsar.functions.instance.stats.SourceStatsManager	From	To
	Extract Method private getExceptionMetricsLabels(ex Throwable, ts long) : String[] extracted from public incrSourceExceptions(ex Throwable) : void in class org.apache.pulsar.functions.instance.stats.SourceStatsManager	From	To
	Extract Method private getExceptionMetricsLabels(ex Throwable, ts long) : String[] extracted from public incrSysExceptions(ex Throwable) : void in class org.apache.pulsar.functions.instance.stats.SinkStatsManager	From	To
	Extract And Move Method	4
	Extract And Move Method private getExceptionInformation(exceptionEntry InstanceCommunication.FunctionStatus.ExceptionInformation) : ExceptionInformation extracted from public fromFunctionStatusProto(status InstanceCommunication.FunctionStatus, assignedWorkerId String) : FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl.GetFunctionStatus & moved to class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl	From	To
	Extract And Move Method private getExceptionInformation(exceptionEntry InstanceCommunication.FunctionStatus.ExceptionInformation) : ExceptionInformation extracted from public fromFunctionStatusProto(status InstanceCommunication.FunctionStatus, assignedWorkerId String) : FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl.GetFunctionStatus & moved to class org.apache.pulsar.functions.worker.rest.api.SinkImpl	From	To
	Extract And Move Method private getExceptionInformation(exceptionEntry InstanceCommunication.FunctionStatus.ExceptionInformation) : ExceptionInformation extracted from public fromFunctionStatusProto(status InstanceCommunication.FunctionStatus, assignedWorkerId String) : SinkStatus.SinkInstanceStatus.SinkInstanceStatusData in class org.apache.pulsar.functions.worker.rest.api.SinkImpl.GetSinkStatus & moved to class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl	From	To
	Extract And Move Method private getExceptionInformation(exceptionEntry InstanceCommunication.FunctionStatus.ExceptionInformation) : ExceptionInformation extracted from public fromFunctionStatusProto(status InstanceCommunication.FunctionStatus, assignedWorkerId String) : SinkStatus.SinkInstanceStatus.SinkInstanceStatusData in class org.apache.pulsar.functions.worker.rest.api.SinkImpl.GetSinkStatus & moved to class org.apache.pulsar.functions.worker.rest.api.SinkImpl	From	To
	Rename Parameter	1
	Rename Parameter originalcodeFileName : String to originalCodeFileName : String in method public createContainer(instanceConfig InstanceConfig, codeFile String, originalCodeFileName String, expectedHealthCheckInterval Long) : ProcessRuntime in class org.apache.pulsar.functions.runtime.ProcessRuntimeFactory	From	To