|
Change Parameter Type savepointStatistics : CompletedCheckpointStatistics to savepointStatistics : CheckpointStatistics.CompletedCheckpointStatistics in method public LatestCheckpoints(completedCheckpointStatistics CheckpointStatistics.CompletedCheckpointStatistics, savepointStatistics CheckpointStatistics.CompletedCheckpointStatistics, failedCheckpointStatistics CheckpointStatistics.FailedCheckpointStatistics, restoredCheckpointStatistics RestoredCheckpointStatistics) in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints |
From |
To |
|
Change Parameter Type completedCheckpointStatistics : CompletedCheckpointStatistics to completedCheckpointStatistics : CheckpointStatistics.CompletedCheckpointStatistics in method public LatestCheckpoints(completedCheckpointStatistics CheckpointStatistics.CompletedCheckpointStatistics, savepointStatistics CheckpointStatistics.CompletedCheckpointStatistics, failedCheckpointStatistics CheckpointStatistics.FailedCheckpointStatistics, restoredCheckpointStatistics RestoredCheckpointStatistics) in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints |
From |
To |
|
Change Parameter Type messageHeaders : MessageHeaders<EmptyRequestBody,R,JobMessageParameters> to messageHeaders : MessageHeaders<EmptyRequestBody,R,M> in method protected AbstractExecutionGraphHandler(localRestAddress CompletableFuture<String>, leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, messageHeaders MessageHeaders<EmptyRequestBody,R,M>, executionGraphCache ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler |
From |
To |
|
Change Parameter Type request : HandlerRequest<EmptyRequestBody,JobMessageParameters> to request : HandlerRequest<EmptyRequestBody,M> in method protected handleRequest(request HandlerRequest<EmptyRequestBody,M>, gateway RestfulGateway) : CompletableFuture<R> in class org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler |
From |
To |
|
Change Parameter Type history : List<BaseCheckpointStatistics> to history : List<CheckpointStatistics> in method public CheckpointingStatistics(counts Counts, summary Summary, latestCheckpoints LatestCheckpoints, history List<CheckpointStatistics>) in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics |
From |
To |
|
Change Parameter Type failedCheckpointStatistics : FailedCheckpointStatistics to failedCheckpointStatistics : CheckpointStatistics.FailedCheckpointStatistics in method public LatestCheckpoints(completedCheckpointStatistics CheckpointStatistics.CompletedCheckpointStatistics, savepointStatistics CheckpointStatistics.CompletedCheckpointStatistics, failedCheckpointStatistics CheckpointStatistics.FailedCheckpointStatistics, restoredCheckpointStatistics RestoredCheckpointStatistics) in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints |
From |
To |
|
Change Return Type Class<CheckpointStatistics> to Class<CheckpointingStatistics> in method public getResponseClass() : Class<CheckpointingStatistics> in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatisticsHeaders |
From |
To |
|
Change Return Type CheckpointStatistics to CheckpointingStatistics in method protected getTestResponseInstance() : CheckpointingStatistics in class org.apache.flink.runtime.rest.handler.legacy.messages.CheckpointingStatisticsTest |
From |
To |
|
Change Return Type CheckpointStatisticsHeaders to CheckpointingStatisticsHeaders in method public getInstance() : CheckpointingStatisticsHeaders in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatisticsHeaders |
From |
To |
|
Change Return Type CompletedCheckpointStatistics to CheckpointStatistics.CompletedCheckpointStatistics in method public getCompletedCheckpointStatistics() : CheckpointStatistics.CompletedCheckpointStatistics in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints |
From |
To |
|
Change Return Type CompletedCheckpointStatistics to CheckpointStatistics.CompletedCheckpointStatistics in method public getSavepointStatistics() : CheckpointStatistics.CompletedCheckpointStatistics in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints |
From |
To |
|
Change Return Type Class<CheckpointStatistics> to Class<CheckpointingStatistics> in method protected getTestResponseClass() : Class<CheckpointingStatistics> in class org.apache.flink.runtime.rest.handler.legacy.messages.CheckpointingStatisticsTest |
From |
To |
|
Change Return Type List<BaseCheckpointStatistics> to List<CheckpointStatistics> in method public getHistory() : List<CheckpointStatistics> in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics |
From |
To |
|
Change Return Type FailedCheckpointStatistics to CheckpointStatistics.FailedCheckpointStatistics in method public getFailedCheckpointStatistics() : CheckpointStatistics.FailedCheckpointStatistics in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints |
From |
To |
|
Move Attribute private triggerTimestamp : long from class org.apache.flink.runtime.rest.messages.CheckpointStatistics.BaseCheckpointStatistics to private triggerTimestamp : long from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics |
From |
To |
|
Move Attribute public FIELD_NAME_STATUS : String from class org.apache.flink.runtime.rest.messages.CheckpointStatistics.BaseCheckpointStatistics to public FIELD_NAME_STATUS : String from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics |
From |
To |
|
Move Attribute public FIELD_NAME_TRIGGER_TIMESTAMP : String from class org.apache.flink.runtime.rest.messages.CheckpointStatistics.BaseCheckpointStatistics to public FIELD_NAME_TRIGGER_TIMESTAMP : String from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics |
From |
To |
|
Move Attribute private id : long from class org.apache.flink.runtime.rest.messages.CheckpointStatistics.BaseCheckpointStatistics to private id : long from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics |
From |
To |
|
Move Attribute private savepoint : boolean from class org.apache.flink.runtime.rest.messages.CheckpointStatistics.BaseCheckpointStatistics to private savepoint : boolean from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics |
From |
To |
|
Move Attribute public FIELD_NAME_ID : String from class org.apache.flink.runtime.rest.messages.CheckpointStatistics.BaseCheckpointStatistics to public FIELD_NAME_ID : String from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics |
From |
To |
|
Move Attribute private status : CheckpointStatsStatus from class org.apache.flink.runtime.rest.messages.CheckpointStatistics.BaseCheckpointStatistics to private status : CheckpointStatsStatus from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics |
From |
To |
|
Move Attribute public FIELD_NAME_IS_SAVEPOINT : String from class org.apache.flink.runtime.rest.messages.CheckpointStatistics.BaseCheckpointStatistics to public FIELD_NAME_IS_SAVEPOINT : String from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics |
From |
To |
|
Change Variable Type checkpointStatisticsHandler : CheckpointStatisticsHandler to checkpointStatisticsHandler : CheckpointingStatisticsHandler in method protected initializeHandlers(restAddressFuture CompletableFuture<String>) : Collection<Tuple2<RestHandlerSpecification,ChannelInboundHandler>> in class org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint |
From |
To |
|
Change Variable Type that : BaseCheckpointStatistics to that : TaskCheckpointStatistics in method public equals(o Object) : boolean in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.TaskCheckpointStatistics |
From |
To |
|
Change Variable Type that : CheckpointStatistics to that : CheckpointingStatistics in method public equals(o Object) : boolean in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics |
From |
To |
|
Change Variable Type summary : CheckpointStatistics.Summary to summary : CheckpointingStatistics.Summary in method protected getTestResponseInstance() : CheckpointingStatistics in class org.apache.flink.runtime.rest.handler.legacy.messages.CheckpointingStatisticsTest |
From |
To |
|
Change Variable Type latestCheckpoints : CheckpointStatistics.LatestCheckpoints to latestCheckpoints : CheckpointingStatistics.LatestCheckpoints in method protected getTestResponseInstance() : CheckpointingStatistics in class org.apache.flink.runtime.rest.handler.legacy.messages.CheckpointingStatisticsTest |
From |
To |
|
Change Variable Type counts : CheckpointStatistics.Counts to counts : CheckpointingStatistics.Counts in method protected getTestResponseInstance() : CheckpointingStatistics in class org.apache.flink.runtime.rest.handler.legacy.messages.CheckpointingStatisticsTest |
From |
To |
|
Change Variable Type restored : CheckpointStatistics.RestoredCheckpointStatistics to restored : CheckpointingStatistics.RestoredCheckpointStatistics in method protected getTestResponseInstance() : CheckpointingStatistics in class org.apache.flink.runtime.rest.handler.legacy.messages.CheckpointingStatisticsTest |
From |
To |
|
Change Attribute Type savepointStatistics : CompletedCheckpointStatistics to savepointStatistics : CheckpointStatistics.CompletedCheckpointStatistics in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints |
From |
To |
|
Change Attribute Type completedCheckpointStatistics : CompletedCheckpointStatistics to completedCheckpointStatistics : CheckpointStatistics.CompletedCheckpointStatistics in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints |
From |
To |
|
Change Attribute Type INSTANCE : CheckpointStatisticsHeaders to INSTANCE : CheckpointingStatisticsHeaders in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatisticsHeaders |
From |
To |
|
Change Attribute Type failedCheckpointStatistics : FailedCheckpointStatistics to failedCheckpointStatistics : CheckpointStatistics.FailedCheckpointStatistics in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.LatestCheckpoints |
From |
To |
|
Change Attribute Type history : List<BaseCheckpointStatistics> to history : List<CheckpointStatistics> in class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics |
From |
To |