|
Change Parameter Type allFunctions : List<FunctionMetaData> to functionInstances : List<Function.Instance> in method private getUnassignedFunctionInstances(currentAssignments Map<String,Map<String,Assignment>>, functionInstances List<Function.Instance>) : List<Function.Instance> in class org.apache.pulsar.functions.worker.SchedulerManager |
From |
To |
|
Change Parameter Type unassignedFunctions : List<FunctionMetaData> to unassignedFunctionInstances : List<Instance> in method public schedule(unassignedFunctionInstances List<Instance>, currentAssignments List<Assignment>, workers List<String>) : List<Assignment> in class org.apache.pulsar.functions.worker.scheduler.IScheduler |
From |
To |
|
Change Parameter Type unassignedFunctions : List<FunctionMetaData> to unassignedFunctionInstances : List<Instance> in method public schedule(unassignedFunctionInstances List<Instance>, currentAssignments List<Assignment>, workers List<String>) : List<Assignment> in class org.apache.pulsar.functions.worker.scheduler.RoundRobinScheduler |
From |
To |
|
Rename Variable unassignedFunction : FunctionMetaData to unassignedFunctionInstance : Instance in method public schedule(unassignedFunctionInstances List<Instance>, currentAssignments List<Assignment>, workers List<String>) : List<Assignment> in class org.apache.pulsar.functions.worker.scheduler.RoundRobinScheduler |
From |
To |
|
Rename Variable functionMetaData : FunctionMetaData to instance : Function.Instance in method private getUnassignedFunctionInstances(currentAssignments Map<String,Map<String,Assignment>>, functionInstances List<Function.Instance>) : List<Function.Instance> in class org.apache.pulsar.functions.worker.SchedulerManager |
From |
To |
|
Rename Variable unassignedFunctions : List<FunctionMetaData> to unassignedFunctionInstances : List<Function.Instance> in method private getUnassignedFunctionInstances(currentAssignments Map<String,Map<String,Assignment>>, functionInstances List<Function.Instance>) : List<Function.Instance> in class org.apache.pulsar.functions.worker.SchedulerManager |
From |
To |
|
Rename Variable fullyQualifiedName : String to fullyQualifiedInstanceId : String in method public processAssignmentUpdate(messageId MessageId, assignmentsUpdate AssignmentsUpdate) : void in class org.apache.pulsar.functions.worker.FunctionRuntimeManager |
From |
To |
|
Rename Variable fullyQualifiedName : String to fullyQualifiedInstanceId : String in method public checkFailures(functionMetaDataManager FunctionMetaDataManager, functionRuntimeManager FunctionRuntimeManager, schedulerManager SchedulerManager) : void in class org.apache.pulsar.functions.worker.MembershipManager |
From |
To |
|
Rename Variable fullyQualifiedName : String to fullyQualifiedInstanceId : String in method private findAssignment(tenant String, namespace String, functionName String, instanceId int) : Assignment in class org.apache.pulsar.functions.worker.FunctionRuntimeManager |
From |
To |
|
Rename Variable fullyQualifiedName : String to instance : Function.Instance in method public checkFailures(functionMetaDataManager FunctionMetaDataManager, functionRuntimeManager FunctionRuntimeManager, schedulerManager SchedulerManager) : void in class org.apache.pulsar.functions.worker.MembershipManager |
From |
To |
|
Rename Variable functionStatus : FunctionStatus to functionStatusList : InstanceCommunication.FunctionStatusList in method public getFunctionStatus(tenant String, namespace String, functionName String) : Response in class org.apache.pulsar.functions.worker.rest.api.v1.ApiV1Resource |
From |
To |
|
Rename Variable fullyQualifiedName : String to fullyQualifiedInstanceId : String in method package deleteAssignment(assignment Assignment) : void in class org.apache.pulsar.functions.worker.FunctionRuntimeManager |
From |
To |
|
Rename Variable fullyQualifiedName : String to fullyQualifiedInstanceId : String in method private getUnassignedFunctionInstances(currentAssignments Map<String,Map<String,Assignment>>, functionInstances List<Function.Instance>) : List<Function.Instance> in class org.apache.pulsar.functions.worker.SchedulerManager |
From |
To |
|
Change Return Type List<FunctionMetaData> to List<Function.Instance> in method private getUnassignedFunctionInstances(currentAssignments Map<String,Map<String,Assignment>>, functionInstances List<Function.Instance>) : List<Function.Instance> in class org.apache.pulsar.functions.worker.SchedulerManager |
From |
To |
|
Change Return Type InstanceCommunication.FunctionStatus to InstanceCommunication.FunctionStatusList in method public getAllFunctionStatus(tenant String, namespace String, functionName String) : InstanceCommunication.FunctionStatusList in class org.apache.pulsar.functions.worker.FunctionRuntimeManager |
From |
To |
|
Change Return Type FunctionStatus to FunctionStatusList in method public getFunctionStatus(tenant String, namespace String, function String) : FunctionStatusList in class org.apache.pulsar.client.admin.Functions |
From |
To |
|
Change Return Type FunctionStatus to FunctionStatusList in method public getFunctionStatus(tenant String, namespace String, function String) : FunctionStatusList in class org.apache.pulsar.client.admin.internal.FunctionsImpl |
From |
To |
|
Change Variable Type functionMetaData : FunctionMetaData to instance : Function.Instance in method private getUnassignedFunctionInstances(currentAssignments Map<String,Map<String,Assignment>>, functionInstances List<Function.Instance>) : List<Function.Instance> in class org.apache.pulsar.functions.worker.SchedulerManager |
From |
To |
|
Change Variable Type unassignedFunction : FunctionMetaData to unassignedFunctionInstance : Instance in method public schedule(unassignedFunctionInstances List<Instance>, currentAssignments List<Assignment>, workers List<String>) : List<Assignment> in class org.apache.pulsar.functions.worker.scheduler.RoundRobinScheduler |
From |
To |
|
Change Variable Type assignment : Function.Assignment to assignment : Assignment in method public getFunctionInstanceStatus(tenant String, namespace String, functionName String, instanceId int) : InstanceCommunication.FunctionStatus in class org.apache.pulsar.functions.worker.FunctionRuntimeManager |
From |
To |
|
Change Variable Type unassignedFunctions : List<FunctionMetaData> to unassignedFunctionInstances : List<Function.Instance> in method private getUnassignedFunctionInstances(currentAssignments Map<String,Map<String,Assignment>>, functionInstances List<Function.Instance>) : List<Function.Instance> in class org.apache.pulsar.functions.worker.SchedulerManager |
From |
To |
|
Change Variable Type fullyQualifiedName : String to instance : Function.Instance in method public checkFailures(functionMetaDataManager FunctionMetaDataManager, functionRuntimeManager FunctionRuntimeManager, schedulerManager SchedulerManager) : void in class org.apache.pulsar.functions.worker.MembershipManager |
From |
To |
|
Change Variable Type needSchedule : Collection<String> to needSchedule : Collection<Function.Instance> in method public checkFailures(functionMetaDataManager FunctionMetaDataManager, functionRuntimeManager FunctionRuntimeManager, schedulerManager SchedulerManager) : void in class org.apache.pulsar.functions.worker.MembershipManager |
From |
To |
|
Change Variable Type functionStatus : FunctionStatus to functionStatusList : InstanceCommunication.FunctionStatusList in method public getFunctionStatus(tenant String, namespace String, functionName String) : Response in class org.apache.pulsar.functions.worker.rest.api.v1.ApiV1Resource |
From |
To |
|
Change Variable Type entry : Map.Entry<String,Long> to entry : Map.Entry<Function.Instance,Long> in method public checkFailures(functionMetaDataManager FunctionMetaDataManager, functionRuntimeManager FunctionRuntimeManager, schedulerManager SchedulerManager) : void in class org.apache.pulsar.functions.worker.MembershipManager |
From |
To |
|
Change Variable Type it : Iterator<Map.Entry<String,Long>> to it : Iterator<Map.Entry<Function.Instance,Long>> in method public checkFailures(functionMetaDataManager FunctionMetaDataManager, functionRuntimeManager FunctionRuntimeManager, schedulerManager SchedulerManager) : void in class org.apache.pulsar.functions.worker.MembershipManager |
From |
To |
|
Rename Parameter fullyQualifiedName : String to fullyQualifiedInstanceId : String in method private deleteFunctionRuntimeInfo(fullyQualifiedInstanceId String) : void in class org.apache.pulsar.functions.worker.FunctionRuntimeManager |
From |
To |
|
Rename Parameter fullyQualifiedName : String to fullyQualifiedInstanceId : String in method private setFunctionRuntimeInfo(fullyQualifiedInstanceId String, functionRuntimeInfo FunctionRuntimeInfo) : void in class org.apache.pulsar.functions.worker.FunctionRuntimeManager |
From |
To |
|
Rename Parameter unassignedFunctions : List<FunctionMetaData> to unassignedFunctionInstances : List<Instance> in method public schedule(unassignedFunctionInstances List<Instance>, currentAssignments List<Assignment>, workers List<String>) : List<Assignment> in class org.apache.pulsar.functions.worker.scheduler.IScheduler |
From |
To |
|
Rename Parameter unassignedFunctions : List<FunctionMetaData> to unassignedFunctionInstances : List<Instance> in method public schedule(unassignedFunctionInstances List<Instance>, currentAssignments List<Assignment>, workers List<String>) : List<Assignment> in class org.apache.pulsar.functions.worker.scheduler.RoundRobinScheduler |
From |
To |
|
Rename Parameter fullyQualifiedName : String to fullyQualifiedInstanceId : String in method private getFunctionRuntimeInfo(fullyQualifiedInstanceId String) : FunctionRuntimeInfo in class org.apache.pulsar.functions.worker.FunctionRuntimeManager |
From |
To |
|
Rename Parameter allFunctions : List<FunctionMetaData> to functionInstances : List<Function.Instance> in method private getUnassignedFunctionInstances(currentAssignments Map<String,Map<String,Assignment>>, functionInstances List<Function.Instance>) : List<Function.Instance> in class org.apache.pulsar.functions.worker.SchedulerManager |
From |
To |