|
Pull Up Method public getParallelism() : Integer from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to public getParallelism() : Integer from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Method public getEntryClassName() : String from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to public getEntryClassName() : String from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Method public reset() : void from class org.apache.flink.runtime.webmonitor.handlers.JarRunHandlerParameterTest to public reset() : void from class org.apache.flink.runtime.webmonitor.handlers.JarHandlerParameterTest |
From |
To |
|
Pull Up Method public JarRunRequestBody(entryClassName String, programArguments String, parallelism Integer, allowNonRestoredState Boolean, savepointPath String) from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to package JarRequestBody(entryClassName String, programArguments String, programArgumentsList List<String>, parallelism Integer) from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Method public getPathParameters() : Collection<MessagePathParameter<?>> from class org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters to public getPathParameters() : Collection<MessagePathParameter<?>> from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Pull Up Method private getExecutionConfig(jobGraph JobGraph) : ExecutionConfig from class org.apache.flink.runtime.webmonitor.handlers.JarRunHandlerParameterTest to private getExecutionConfig(jobGraph JobGraph) : ExecutionConfig from class org.apache.flink.runtime.webmonitor.handlers.JarHandlerParameterTest |
From |
To |
|
Pull Up Method public getQueryParameters() : Collection<MessageQueryParameter<?>> from class org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters to public getQueryParameters() : Collection<MessageQueryParameter<?>> from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Pull Up Method public getProgramArguments() : String from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to public getProgramArguments() : String from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Method public testDefaultParameters() : void from class org.apache.flink.runtime.webmonitor.handlers.JarRunHandlerParameterTest to public testDefaultParameters() : void from class org.apache.flink.runtime.webmonitor.handlers.JarHandlerParameterTest |
From |
To |
|
Pull Up Method private getValuesAsString(parameter MessageQueryParameter<X>) : List<String> from class org.apache.flink.runtime.webmonitor.handlers.JarRunHandlerParameterTest to private getValuesAsString(parameter MessageQueryParameter<X>) : List<String> from class org.apache.flink.runtime.webmonitor.handlers.JarHandlerParameterTest |
From |
To |
|
Pull Up Method public getPathParameters() : Collection<MessagePathParameter<?>> from class org.apache.flink.runtime.webmonitor.handlers.JarRunMessageParameters to public getPathParameters() : Collection<MessagePathParameter<?>> from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Change Parameter Type messageHeaders : MessageHeaders<EmptyRequestBody,JobPlanInfo,JarPlanMessageParameters> to messageHeaders : MessageHeaders<JarPlanRequestBody,JobPlanInfo,JarPlanMessageParameters> in method public JarPlanHandler(localRestAddress CompletableFuture<String>, leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders MessageHeaders<JarPlanRequestBody,JobPlanInfo,JarPlanMessageParameters>, jarDir Path, configuration Configuration, executor Executor, planGenerator Function<JobGraph,JobPlanInfo>) in class org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler |
From |
To |
|
Pull Up Attribute private FIELD_NAME_PROGRAM_ARGUMENTS : String from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to package FIELD_NAME_PROGRAM_ARGUMENTS : String from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Attribute private restfulGateway : TestingDispatcherGateway from class org.apache.flink.runtime.webmonitor.handlers.JarRunHandlerParameterTest to package restfulGateway : TestingDispatcherGateway from class org.apache.flink.runtime.webmonitor.handlers.JarHandlerParameterTest |
From |
To |
|
Pull Up Attribute public parallelismQueryParameter : ParallelismQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarRunMessageParameters to package parallelismQueryParameter : ParallelismQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Pull Up Attribute private FIELD_NAME_ENTRY_CLASS : String from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to package FIELD_NAME_ENTRY_CLASS : String from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Attribute private FIELD_NAME_PARALLELISM : String from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to package FIELD_NAME_PARALLELISM : String from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Attribute private programArgsQueryParameter : ProgramArgsQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters to package programArgsQueryParameter : ProgramArgsQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Pull Up Attribute public TMP : TemporaryFolder from class org.apache.flink.runtime.webmonitor.handlers.JarRunHandlerParameterTest to public TMP : TemporaryFolder from class org.apache.flink.runtime.webmonitor.handlers.JarHandlerParameterTest |
From |
To |
|
Pull Up Attribute public entryClassQueryParameter : EntryClassQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarRunMessageParameters to package entryClassQueryParameter : EntryClassQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Pull Up Attribute public BLOB_SERVER_RESOURCE : BlobServerResource from class org.apache.flink.runtime.webmonitor.handlers.JarRunHandlerParameterTest to public BLOB_SERVER_RESOURCE : BlobServerResource from class org.apache.flink.runtime.webmonitor.handlers.JarHandlerParameterTest |
From |
To |
|
Pull Up Attribute private jarWithoutManifest : Path from class org.apache.flink.runtime.webmonitor.handlers.JarRunHandlerParameterTest to private jarWithoutManifest : Path from class org.apache.flink.runtime.webmonitor.handlers.JarHandlerParameterTest |
From |
To |
|
Pull Up Attribute private entryClassQueryParameter : EntryClassQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters to package entryClassQueryParameter : EntryClassQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Pull Up Attribute private parallelism : Integer from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to private parallelism : Integer from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Attribute private entryClassName : String from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to private entryClassName : String from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Attribute public programArgsQueryParameter : ProgramArgsQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarRunMessageParameters to package programArgsQueryParameter : ProgramArgsQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Pull Up Attribute private jarWithManifest : Path from class org.apache.flink.runtime.webmonitor.handlers.JarRunHandlerParameterTest to private jarWithManifest : Path from class org.apache.flink.runtime.webmonitor.handlers.JarHandlerParameterTest |
From |
To |
|
Pull Up Attribute private programArguments : String from class org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody to private programArguments : String from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody |
From |
To |
|
Pull Up Attribute private parallelismQueryParameter : ParallelismQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters to package parallelismQueryParameter : ParallelismQueryParameter from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Pull Up Attribute public jarIdPathParameter : JarIdPathParameter from class org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters to package jarIdPathParameter : JarIdPathParameter from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |
|
Pull Up Attribute public jarIdPathParameter : JarIdPathParameter from class org.apache.flink.runtime.webmonitor.handlers.JarRunMessageParameters to package jarIdPathParameter : JarIdPathParameter from class org.apache.flink.runtime.webmonitor.handlers.JarMessageParameters |
From |
To |