|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public ExecutionGraphHolder(timeout Time) in class org.apache.flink.runtime.webmonitor.ExecutionGraphHolder |
From |
To |
|
Change Parameter Type executionContext : ExecutionContext to executor : Executor in method public TriggerHandler(currentGraphs ExecutionGraphHolder, executor Executor) in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.TriggerHandler |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public StaticFileServerHandler(retriever JobManagerRetriever, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, rootPath File, httpsEnabled boolean, logger Logger) in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method protected abstract respondAsLeader(ctx ChannelHandlerContext, routed Routed, jobManagerGateway JobManagerGateway) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public TaskManagersHandler(timeout Time, fetcher MetricFetcher) in class org.apache.flink.runtime.webmonitor.handlers.TaskManagersHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.CurrentJobIdsHandler |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public RuntimeMonitorHandlerBase(retriever JobManagerRetriever, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationHandler |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public StaticFileServerHandler(retriever JobManagerRetriever, localJobManagerAddressPromise CompletableFuture<String>, timeout Time, rootPath File, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.RequestHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarAccessDeniedHandler |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public JarRunHandler(jarDirectory File, timeout Time, clientConfig Configuration) in class org.apache.flink.runtime.webmonitor.handlers.JarRunHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarUploadHandler |
From |
To |
|
Change Parameter Type executionContext : ExecutionContext to executor : Executor in method public JobCancellationWithSavepointHandlers(currentGraphs ExecutionGraphHolder, executor Executor) in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.CurrentJobsOverviewHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.metrics.AbstractMetricsHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.ClusterOverviewHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method protected respondAsLeader(ctx ChannelHandlerContext, routed Routed, jobManagerGateway JobManagerGateway) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JobManagerConfigHandler |
From |
To |
|
Change Parameter Type executionContext : ExecutionContext to executor : Executor in method public JobCancellationWithSavepointHandlers(currentGraphs ExecutionGraphHolder, executor Executor, defaultSavepointDirectory String) in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.AbstractExecutionGraphRequestHandler |
From |
To |
|
Change Parameter Type localJobManagerAddressFuture : Future<String> to localJobManagerAddressFuture : CompletableFuture<String> in method public StaticFileServerHandler(retriever JobManagerRetriever, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, rootPath File, httpsEnabled boolean, logger Logger) in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.AbstractJsonRequestHandler |
From |
To |
|
Change Parameter Type localJobManagerAddressFuture : Future<String> to localJobManagerAddressFuture : CompletableFuture<String> in method public RuntimeMonitorHandlerBase(retriever JobManagerRetriever, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Change Parameter Type executor : ExecutionContextExecutor to executor : Executor in method public TaskManagerLogHandler(retriever JobManagerRetriever, executor Executor, localJobManagerAddressPromise CompletableFuture<String>, timeout Time, fileMode FileMode, config Configuration, httpsEnabled boolean, blobView BlobView) in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method private handleNewRequest(jobManagerGateway JobManagerGateway, jobId JobID, targetDirectory String, checkpointTimeout long) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.TriggerHandler |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public ClusterOverviewHandler(timeout Time) in class org.apache.flink.runtime.webmonitor.handlers.ClusterOverviewHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarDeleteHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.InProgressHandler |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public RuntimeMonitorHandler(cfg WebMonitorConfig, handler RequestHandler, retriever JobManagerRetriever, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarRunHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public abstract handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.AbstractJsonRequestHandler |
From |
To |
|
Change Parameter Type localJobManagerAddressFuture : Future<String> to localJobManagerAddressFuture : CompletableFuture<String> in method public RuntimeMonitorHandler(cfg WebMonitorConfig, handler RequestHandler, retriever JobManagerRetriever, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public TaskManagerLogHandler(retriever JobManagerRetriever, executor Executor, localJobManagerAddressPromise CompletableFuture<String>, timeout Time, fileMode FileMode, config Configuration, httpsEnabled boolean, blobView BlobView) in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandler |
From |
To |
|
Change Parameter Type ctx : ExecutionContext to executor : Executor in method public MetricFetcher(retriever JobManagerRetriever, queryServiceRetriever MetricQueryServiceRetriever, executor Executor, timeout Time) in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcher |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public CurrentJobsOverviewHandler(timeout Time, includeRunningJobs boolean, includeFinishedJobs boolean) in class org.apache.flink.runtime.webmonitor.handlers.CurrentJobsOverviewHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method protected respondAsLeader(ctx ChannelHandlerContext, routed Routed, jobManagerGateway JobManagerGateway) : void in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.TaskManagersHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JobStoppingHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.TriggerHandler |
From |
To |
|
Change Parameter Type timeout : FiniteDuration to timeout : Time in method public CurrentJobIdsHandler(timeout Time) in class org.apache.flink.runtime.webmonitor.handlers.CurrentJobIdsHandler |
From |
To |
|
Change Parameter Type localJobManagerAddressPromise : Future<String> to localJobManagerAddressPromise : CompletableFuture<String> in method public TaskManagerLogHandler(retriever JobManagerRetriever, executor Executor, localJobManagerAddressPromise CompletableFuture<String>, timeout Time, fileMode FileMode, config Configuration, httpsEnabled boolean, blobView BlobView) in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.DashboardConfigHandler |
From |
To |
|
Change Parameter Type localJobManagerAddressPromise : Future<String> to localJobManagerAddressPromise : CompletableFuture<String> in method public StaticFileServerHandler(retriever JobManagerRetriever, localJobManagerAddressPromise CompletableFuture<String>, timeout Time, rootPath File, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Parameter Type jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarListHandler |
From |
To |
|
Rename Variable leader : Tuple2<ActorGateway,Integer> to jobManagerGateway : JobManagerGateway in method public testGetRedirectAddressWithLocalAkkaPath() : void in class org.apache.flink.runtime.webmonitor.handlers.HandlerRedirectUtilsTest |
From |
To |
|
Rename Variable taskManager : Instance to taskManagerInstance : Instance in method protected respondAsLeader(ctx ChannelHandlerContext, routed Routed, jobManagerGateway JobManagerGateway) : void in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandler |
From |
To |
|
Rename Variable leader : Tuple2<ActorGateway,Integer> to jobManagerGateway : JobManagerGateway in method public testGetRedirectAddressWithRemoteAkkaPath() : void in class org.apache.flink.runtime.webmonitor.handlers.HandlerRedirectUtilsTest |
From |
To |
|
Rename Variable queryServicePath : String to jmQueryServicePath : String in method private fetchMetrics() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcher |
From |
To |
|
Rename Variable jobManagerGatewayAndWebPort : Option<scala.Tuple2<ActorGateway,Integer>> to optJobManagerGateway : Optional<JobManagerGateway> in method private fetchMetrics() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcher |
From |
To |
|
Rename Variable promise : Promise<Object> to successfulCancelWithSavepoint : CompletableFuture<String> in method public testTriggerNewRequest() : void in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Rename Variable future : Future<Object> to unsuccessfulCancelWithSavepoint : CompletableFuture<String> in method public testFailedCancellation() : void in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Rename Variable jobManager : Option<Tuple2<ActorGateway,Integer>> to optJobManagerGateway : Optional<JobManagerGateway> in method protected channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Rename Variable eg : AccessExecutionGraph to graph : AccessExecutionGraph in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.AbstractExecutionGraphRequestHandler |
From |
To |
|
Rename Variable gatewayPort : Tuple2<ActorGateway,Integer> to jobManagerGateway : JobManagerGateway in method protected channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Rename Variable jobid : JobID to jobId : JobID in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationHandler |
From |
To |
|
Rename Variable actorSystem : ActorSystem to queryServiceRetriever : MetricQueryServiceRetriever in method public testUpdate() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcherTest |
From |
To |
|
Rename Variable jobid : JobID to jobId : JobID in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JobStoppingHandler |
From |
To |
|
Rename Variable jobManager : Option<Tuple2<ActorGateway,Integer>> to optJobManagerGateway : Optional<JobManagerGateway> in method public channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Variable Type jobManager : ActorGateway to jobManager : JobManagerGateway in method public testTriggerNewRequest() : void in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Change Variable Type jobManagerGatewayAndWebPort : Option<scala.Tuple2<ActorGateway,Integer>> to optJobManagerGateway : Optional<JobManagerGateway> in method private fetchMetrics() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcher |
From |
To |
|
Change Variable Type jobManagerGateway : ActorGateway to jobManagerGateway : JobManagerGateway in method public testLogFetchingFailure() : void in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandlerTest |
From |
To |
|
Change Variable Type promise : Promise<Object> to successfulCancelWithSavepoint : CompletableFuture<String> in method public testTriggerNewRequest() : void in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Change Variable Type requestMetricsAnswer : Object to requestMetricsAnswer : MetricDumpSerialization.MetricSerializationResult in method public testUpdate() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcherTest |
From |
To |
|
Change Variable Type future : Future<Object> to unsuccessfulCancelWithSavepoint : CompletableFuture<String> in method public testFailedCancellation() : void in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Change Variable Type jobManager : Option<Tuple2<ActorGateway,Integer>> to optJobManagerGateway : Optional<JobManagerGateway> in method protected channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Change Variable Type gatewayPort : Tuple2<ActorGateway,Integer> to jobManagerGateway : JobManagerGateway in method protected channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Change Variable Type jobManager : ActorGateway to jobManager : JobManagerGateway in method public testSavepointDirectoryConfiguration() : void in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Change Variable Type jobManagerGateway : ActorGateway to jobManagerGateway : JobManagerGateway in method public testUpdate() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcherTest |
From |
To |
|
Change Variable Type retriever : JobManagerRetriever to retriever : AkkaJobManagerRetriever in method public testUpdate() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcherTest |
From |
To |
|
Change Variable Type actorSystem : ActorSystem to queryServiceRetriever : MetricQueryServiceRetriever in method public testUpdate() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcherTest |
From |
To |
|
Change Variable Type jobManager : Option<Tuple2<ActorGateway,Integer>> to optJobManagerGateway : Optional<JobManagerGateway> in method public channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Variable Type context : ExecutionContextExecutor to executor : Executor in method public WebRuntimeMonitor(config Configuration, leaderRetrievalService LeaderRetrievalService, blobView BlobView, jobManagerRetriever JobManagerRetriever, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, executor Executor) in class org.apache.flink.runtime.webmonitor.WebRuntimeMonitor |
From |
To |
|
Change Variable Type leader : Tuple2<ActorGateway,Integer> to jobManagerGateway : JobManagerGateway in method public testGetRedirectAddressWithLocalAkkaPath() : void in class org.apache.flink.runtime.webmonitor.handlers.HandlerRedirectUtilsTest |
From |
To |
|
Change Variable Type jobManager : ActorGateway to jobManager : JobManagerGateway in method public testAskTimeoutEqualsCheckpointTimeout() : void in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Change Variable Type leader : Tuple2<ActorGateway,Integer> to jobManagerGateway : JobManagerGateway in method public testGetRedirectAddressWithRemoteAkkaPath() : void in class org.apache.flink.runtime.webmonitor.handlers.HandlerRedirectUtilsTest |
From |
To |
|
Change Variable Type jobManager : ActorGateway to jobManager : JobManagerGateway in method public testFailedCancellation() : void in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlersTest |
From |
To |
|
Rename Parameter ctx : ExecutionContext to executor : Executor in method public MetricFetcher(retriever JobManagerRetriever, queryServiceRetriever MetricQueryServiceRetriever, executor Executor, timeout Time) in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcher |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.TriggerHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.CurrentJobIdsHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JobManagerConfigHandler |
From |
To |
|
Rename Parameter executionContext : ExecutionContext to executor : Executor in method public JobCancellationWithSavepointHandlers(currentGraphs ExecutionGraphHolder, executor Executor, defaultSavepointDirectory String) in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method private handleNewRequest(jobManagerGateway JobManagerGateway, jobId JobID, targetDirectory String, checkpointTimeout long) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.TriggerHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.RequestHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarUploadHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JobStoppingHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public abstract handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.AbstractJsonRequestHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.DashboardConfigHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.AbstractExecutionGraphRequestHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.AbstractJsonRequestHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarDeleteHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarListHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method protected respondAsLeader(ctx ChannelHandlerContext, routed Routed, jobManagerGateway JobManagerGateway) : void in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.TaskManagersHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : FullHttpResponse in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.InProgressHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.checkpoints.CheckpointStatsDetailsSubtasksHandler |
From |
To |
|
Rename Parameter executionContext : ExecutionContext to executor : Executor in method public TriggerHandler(currentGraphs ExecutionGraphHolder, executor Executor) in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers.TriggerHandler |
From |
To |
|
Rename Parameter executionContext : ExecutionContext to executor : Executor in method public JobCancellationWithSavepointHandlers(currentGraphs ExecutionGraphHolder, executor Executor) in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationWithSavepointHandlers |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.metrics.AbstractMetricsHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JobCancellationHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarAccessDeniedHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.CurrentJobsOverviewHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method protected abstract respondAsLeader(ctx ChannelHandlerContext, routed Routed, jobManagerGateway JobManagerGateway) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.ClusterOverviewHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method public handleJsonRequest(pathParams Map<String,String>, queryParams Map<String,String>, jobManagerGateway JobManagerGateway) : String in class org.apache.flink.runtime.webmonitor.handlers.JarRunHandler |
From |
To |
|
Rename Parameter jobManager : ActorGateway to jobManagerGateway : JobManagerGateway in method protected respondAsLeader(ctx ChannelHandlerContext, routed Routed, jobManagerGateway JobManagerGateway) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler |
From |
To |