|
Change Parameter Type metricFetcher : MetricFetcher<?> to metricFetcher : MetricFetcher in method public JobDetailsHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders MessageHeaders<EmptyRequestBody,JobDetailsInfo,JobMessageParameters>, executionGraphCache ExecutionGraphCache, executor Executor, metricFetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.job.JobDetailsHandler |
From |
To |
|
Change Parameter Type metricFetcher : MetricFetcher<?> to metricFetcher : MetricFetcher in method private createJobDetailsInfo(executionGraph AccessExecutionGraph, metricFetcher MetricFetcher) : JobDetailsInfo in class org.apache.flink.runtime.rest.handler.job.JobDetailsHandler |
From |
To |
|
Change Parameter Type fetcher : MetricFetcher<?> to fetcher : MetricFetcher in method public AggregatingJobsMetricsHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, executor Executor, fetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.job.metrics.AggregatingJobsMetricsHandler |
From |
To |
|
Change Parameter Type metricFetcher : MetricFetcher<?> to metricFetcher : MetricFetcher in method private createDetailsInfo(execution AccessExecution, jobID JobID, jobVertexID JobVertexID, metricFetcher MetricFetcher) : SubtaskExecutionAttemptDetailsInfo in class org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler |
From |
To |
|
Change Parameter Type fetcher : MetricFetcher<?> to fetcher : MetricFetcher in method protected getHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, executor Executor, fetcher MetricFetcher) : AggregatingSubtasksMetricsHandler in class org.apache.flink.runtime.rest.handler.job.metrics.AggregatingSubtasksMetricsHandlerTest |
From |
To |
|
Change Parameter Type metricFetcher : MetricFetcher<?> to metricFetcher : MetricFetcher in method public JobVertexTaskManagersHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders MessageHeaders<EmptyRequestBody,JobVertexTaskManagersInfo,JobVertexMessageParameters>, executionGraphCache ExecutionGraphCache, executor Executor, metricFetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler |
From |
To |
|
Change Parameter Type metricFetcher : MetricFetcher<?> to metricFetcher : MetricFetcher in method public SubtaskCurrentAttemptDetailsHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters>, executionGraphCache ExecutionGraphCache, executor Executor, metricFetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.job.SubtaskCurrentAttemptDetailsHandler |
From |
To |
|
Change Parameter Type fetcher : MetricFetcher<?> to fetcher : MetricFetcher in method public AggregatingTaskManagersMetricsHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, executor Executor, fetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.job.metrics.AggregatingTaskManagersMetricsHandler |
From |
To |
|
Change Parameter Type metricFetcher : MetricFetcher<?> to metricFetcher : MetricFetcher in method private createJobVertexDetailsInfo(jobVertex AccessExecutionJobVertex, jobID JobID, metricFetcher MetricFetcher) : JobVertexDetailsInfo in class org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler |
From |
To |
|
Change Parameter Type fetcher : MetricFetcher<?> to fetcher : MetricFetcher in method protected getHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, executor Executor, fetcher MetricFetcher) : AggregatingJobsMetricsHandler in class org.apache.flink.runtime.rest.handler.job.metrics.AggregatingJobsMetricsHandlerTest |
From |
To |
|
Change Parameter Type fetcher : MetricFetcher<?> to fetcher : MetricFetcher in method public AggregatingSubtasksMetricsHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, executor Executor, fetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.job.metrics.AggregatingSubtasksMetricsHandler |
From |
To |
|
Change Parameter Type metricFetcher : MetricFetcher<?> to metricFetcher : MetricFetcher in method private createJobVertexTaskManagersInfo(jobVertex AccessExecutionJobVertex, jobID JobID, metricFetcher MetricFetcher) : JobVertexTaskManagersInfo in class org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler |
From |
To |
|
Change Parameter Type metricFetcher : MetricFetcher<?> to metricFetcher : MetricFetcher in method private createJobVertexDetailsInfo(ejv AccessExecutionJobVertex, now long, jobId JobID, metricFetcher MetricFetcher) : JobDetailsInfo.JobVertexDetailsInfo in class org.apache.flink.runtime.rest.handler.job.JobDetailsHandler |
From |
To |
|
Change Parameter Type metricFetcher : MetricFetcher<?> to metricFetcher : MetricFetcher in method public SubtaskExecutionAttemptDetailsHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskAttemptMessageParameters>, executionGraphCache ExecutionGraphCache, executor Executor, metricFetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler |
From |
To |
|
Change Parameter Type metricFetcher : MetricFetcher<? extends RestfulGateway> to metricFetcher : MetricFetcher in method public JobVertexDetailsHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders MessageHeaders<EmptyRequestBody,JobVertexDetailsInfo,JobVertexMessageParameters>, executionGraphCache ExecutionGraphCache, executor Executor, metricFetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler |
From |
To |
|
Change Parameter Type fetcher : MetricFetcher<?> to fetcher : MetricFetcher in method protected AbstractAggregatingMetricsHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders AbstractAggregatedMetricsHeaders<P>, executor Executor, fetcher MetricFetcher) in class org.apache.flink.runtime.rest.handler.job.metrics.AbstractAggregatingMetricsHandler |
From |
To |
|
Change Parameter Type fetcher : MetricFetcher<?> to fetcher : MetricFetcher in method protected getHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, executor Executor, fetcher MetricFetcher) : AggregatingTaskManagersMetricsHandler in class org.apache.flink.runtime.rest.handler.job.metrics.AggregatingTaskManagersMetricsHandlerTest |
From |
To |
|
Push Down Attribute private LOG : Logger from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcher to private LOG : Logger from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |
|
Push Down Attribute private timeout : Time from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcher to private timeout : Time from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |
|
Push Down Attribute private lastUpdateTime : long from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcher to private lastUpdateTime : long from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |
|
Push Down Attribute private retriever : GatewayRetriever<T> from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcher to private retriever : GatewayRetriever<T> from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |
|
Push Down Attribute private deserializer : MetricDumpDeserializer from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcher to private deserializer : MetricDumpDeserializer from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |
|
Push Down Attribute private metrics : MetricStore from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcher to private metrics : MetricStore from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |
|
Push Down Attribute private executor : Executor from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcher to private executor : Executor from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |
|
Push Down Attribute private queryServiceRetriever : MetricQueryServiceRetriever from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcher to private queryServiceRetriever : MetricQueryServiceRetriever from class org.apache.flink.runtime.rest.handler.legacy.metrics.MetricFetcherImpl |
From |
To |