|
Change Variable Type t : InstanceCommunication.FunctionStatusResponseProto to t : InstanceCommunication.FunctionStatus in method public getFunctionStatus() : CompletableFuture<FunctionStatus> in class org.apache.pulsar.functions.runtime.container.ProcessFunctionContainer |
From |
To |
|
Change Variable Type retval : FunctionStatus to functionStatusBuilder : FunctionStatus.Builder in method public getFunctionStatus() : CompletableFuture<FunctionStatus> in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer |
From |
To |
|
Change Variable Type response : ListenableFuture<InstanceCommunication.FunctionStatusResponseProto> to response : ListenableFuture<FunctionStatus> in method public getFunctionStatus() : CompletableFuture<FunctionStatus> in class org.apache.pulsar.functions.runtime.container.ProcessFunctionContainer |
From |
To |
|
Change Variable Type response : InstanceCommunication.FunctionStatusResponseProto to response : InstanceCommunication.FunctionStatus in method public getFunctionStatus(request Empty, responseObserver StreamObserver<InstanceCommunication.FunctionStatus>) : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceMain.InstanceControlImpl |
From |
To |