|
Change Parameter Type savepointTriggerId : SavepointTriggerId to triggerId : TriggerId in method private of(triggerId TriggerId, jobId JobID) : SavepointKey in class org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers.SavepointKey |
From |
To |
|
Change Parameter Type actual : SavepointResponseBody to actual : SavepointInfo in method protected assertOriginalEqualsToUnmarshalled(expected SavepointInfo, actual SavepointInfo) : void in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointInfoMarshallingTest |
From |
To |
|
Change Parameter Type expected : SavepointResponseBody to expected : SavepointInfo in method protected assertOriginalEqualsToUnmarshalled(expected SavepointInfo, actual SavepointInfo) : void in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointInfoMarshallingTest |
From |
To |
|
Change Parameter Type actual : SavepointTriggerResponseBody to actual : TriggerResponse in method protected assertOriginalEqualsToUnmarshalled(expected TriggerResponse, actual TriggerResponse) : void in class org.apache.flink.runtime.rest.handler.async.TriggerResponseTest |
From |
To |
|
Change Parameter Type expected : SavepointTriggerResponseBody to expected : TriggerResponse in method protected assertOriginalEqualsToUnmarshalled(expected TriggerResponse, actual TriggerResponse) : void in class org.apache.flink.runtime.rest.handler.async.TriggerResponseTest |
From |
To |
|
Change Parameter Type value : SavepointTriggerId to value : TriggerId in method protected convertToString(value TriggerId) : String in class org.apache.flink.runtime.rest.messages.TriggerIdPathParameter |
From |
To |
|
Change Parameter Type value : SavepointTriggerId to value : TriggerId in method public serialize(value TriggerId, gen JsonGenerator, provider SerializerProvider) : void in class org.apache.flink.runtime.rest.messages.TriggerId.TriggerIdSerializer |
From |
To |
|
Change Parameter Type savepointTriggerId : SavepointTriggerId to triggerId : TriggerId in method private savepointStatusRequest(triggerId TriggerId) : HandlerRequest<EmptyRequestBody,SavepointStatusMessageParameters> in class org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlersTest |
From |
To |
|
Change Parameter Type savepointTriggerId : SavepointTriggerId to triggerID : TriggerId in method private pollSavepointAsync(jobId JobID, triggerID TriggerId) : CompletableFuture<SavepointInfo> in class org.apache.flink.client.program.rest.RestClusterClient |
From |
To |
|
Change Parameter Type savepointResponseBody : SavepointResponseBody to savepointInfo : SavepointInfo in method public SavepointInfoMarshallingTest(savepointInfo SavepointInfo) in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointInfoMarshallingTest |
From |
To |
|
Change Return Type SavepointResponseBody to SavepointInfo in method protected getTestResponseInstance() : SavepointInfo in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointInfoMarshallingTest |
From |
To |
|
Change Return Type SavepointTriggerId to TriggerId in method protected convertFromString(value String) : TriggerId in class org.apache.flink.runtime.rest.messages.TriggerIdPathParameter |
From |
To |
|
Change Return Type Class<SavepointResponseBody> to Class<SavepointInfo> in method protected getTestResponseClass() : Class<SavepointInfo> in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointInfoMarshallingTest |
From |
To |
|
Change Return Type CompletableFuture<SavepointResponseBody> to CompletableFuture<AsynchronousOperationResult<SavepointInfo>> in method protected handleRequest(request HandlerRequest<EmptyRequestBody,SavepointStatusMessageParameters>, gateway DispatcherGateway) : CompletableFuture<AsynchronousOperationResult<SavepointInfo>> in class org.apache.flink.client.program.rest.RestClusterClientTest.TestSavepointHandlers.TestSavepointHandler |
From |
To |
|
Change Return Type Class<SavepointTriggerResponseBody> to Class<TriggerResponse> in method protected getTestResponseClass() : Class<TriggerResponse> in class org.apache.flink.runtime.rest.handler.async.TriggerResponseTest |
From |
To |
|
Change Return Type SavepointTriggerId to TriggerId in method public deserialize(p JsonParser, ctxt DeserializationContext) : TriggerId in class org.apache.flink.runtime.rest.messages.TriggerId.TriggerIdDeserializer |
From |
To |
|
Change Return Type SavepointTriggerId to TriggerId in method public fromHexString(hexString String) : TriggerId in class org.apache.flink.runtime.rest.messages.TriggerId |
From |
To |
|
Change Return Type CompletableFuture<SavepointTriggerResponseBody> to CompletableFuture<TriggerResponse> in method protected handleRequest(request HandlerRequest<SavepointTriggerRequestBody,SavepointTriggerMessageParameters>, gateway DispatcherGateway) : CompletableFuture<TriggerResponse> in class org.apache.flink.client.program.rest.RestClusterClientTest.TestSavepointHandlers.TestSavepointTriggerHandler |
From |
To |
|
Change Return Type SavepointTriggerId to TriggerId in method public getTriggerId() : TriggerId in class org.apache.flink.runtime.rest.handler.async.TriggerResponse |
From |
To |
|
Change Return Type SavepointInfo to V in method public resource() : V in class org.apache.flink.runtime.rest.handler.async.AsynchronousOperationResult |
From |
To |
|
Change Return Type SavepointTriggerResponseBody to TriggerResponse in method protected getTestResponseInstance() : TriggerResponse in class org.apache.flink.runtime.rest.handler.async.TriggerResponseTest |
From |
To |
|
Move And Rename Class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerResponseBodyTest moved and renamed to org.apache.flink.runtime.rest.handler.async.TriggerResponseTest |
From |
To |
|
Move And Rename Class org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers.UnknownSavepointKeyException moved and renamed to org.apache.flink.runtime.rest.handler.async.AbstractAsynchronousOperationHandlers.UnknownOperationKey |
From |
To |
|
Move And Rename Class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerId.SavepointTriggerIdDeserializer moved and renamed to org.apache.flink.runtime.rest.messages.TriggerId.TriggerIdDeserializer |
From |
To |
|
Move And Rename Class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerId moved and renamed to org.apache.flink.runtime.rest.messages.TriggerId |
From |
To |
|
Move And Rename Class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerId.SavepointTriggerIdSerializer moved and renamed to org.apache.flink.runtime.rest.messages.TriggerId.TriggerIdSerializer |
From |
To |
|
Move And Rename Class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerResponseBody moved and renamed to org.apache.flink.runtime.rest.handler.async.TriggerResponse |
From |
To |
|
Move And Rename Class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointResponseBody moved and renamed to org.apache.flink.runtime.rest.handler.async.AsynchronousOperationResult |
From |
To |
|
Change Variable Type savepointTriggerId : SavepointTriggerId to triggerId : TriggerId in method public testSavepointCompletedWithException() : void in class org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlersTest |
From |
To |
|
Change Variable Type responseFuture : CompletableFuture<SavepointTriggerResponseBody> to responseFuture : CompletableFuture<TriggerResponse> in method public triggerSavepoint(jobId JobID, savepointDirectory String) : CompletableFuture<String> in class org.apache.flink.client.program.rest.RestClusterClient |
From |
To |
|
Change Variable Type savepointResponseBody : SavepointResponseBody to savepointResponseBody : AsynchronousOperationResult<SavepointInfo> in method public testSavepointCompletedSuccessfully() : void in class org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlersTest |
From |
To |
|
Change Variable Type savepointTriggerId : SavepointTriggerId to triggerId : TriggerId in method public testSavepointCompletedSuccessfully() : void in class org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlersTest |
From |
To |
|
Change Variable Type savepointTriggerId : SavepointTriggerId to triggerId : TriggerId in method protected handleRequest(request HandlerRequest<EmptyRequestBody,SavepointStatusMessageParameters>, gateway DispatcherGateway) : CompletableFuture<AsynchronousOperationResult<SavepointInfo>> in class org.apache.flink.client.program.rest.RestClusterClientTest.TestSavepointHandlers.TestSavepointHandler |
From |
To |
|
Change Variable Type savepointResponseBody : SavepointResponseBody to savepointResponseBody : AsynchronousOperationResult<SavepointInfo> in method public testSavepointCompletedWithException() : void in class org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlersTest |
From |
To |
|
Rename Parameter savepointTriggerId : SavepointTriggerId to triggerId : TriggerId in method private of(triggerId TriggerId, jobId JobID) : SavepointKey in class org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers.SavepointKey |
From |
To |
|
Rename Parameter savepointTriggerId : SavepointTriggerId to triggerID : TriggerId in method private pollSavepointAsync(jobId JobID, triggerID TriggerId) : CompletableFuture<SavepointInfo> in class org.apache.flink.client.program.rest.RestClusterClient |
From |
To |
|
Rename Parameter savepointTriggerId : SavepointTriggerId to triggerId : TriggerId in method private savepointStatusRequest(triggerId TriggerId) : HandlerRequest<EmptyRequestBody,SavepointStatusMessageParameters> in class org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlersTest |
From |
To |
|
Rename Parameter savepointResponseBody : SavepointResponseBody to savepointInfo : SavepointInfo in method public SavepointInfoMarshallingTest(savepointInfo SavepointInfo) in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointInfoMarshallingTest |
From |
To |
|
Rename Parameter status : QueueStatus to queueStatus : QueueStatus in method private AsynchronousOperationResult(queueStatus QueueStatus, value V) in class org.apache.flink.runtime.rest.handler.async.AsynchronousOperationResult |
From |
To |