Class JarRunRequestBody
- java.lang.Object
-
- org.apache.flink.runtime.webmonitor.handlers.JarRequestBody
-
- org.apache.flink.runtime.webmonitor.handlers.JarRunRequestBody
-
- All Implemented Interfaces:
RequestBody
public class JarRunRequestBody extends JarRequestBody
RequestBody
for running a jar.
-
-
Constructor Summary
Constructors Constructor Description JarRunRequestBody()
JarRunRequestBody(String entryClassName, List<String> programArgumentsList, Integer parallelism, JobID jobId, Boolean allowNonRestoredState, String savepointPath, RecoveryClaimMode recoveryClaimMode, Map<String,String> flinkConfiguration)
Fallback constructor ONLY for tests.JarRunRequestBody(String entryClassName, List<String> programArgumentsList, Integer parallelism, JobID jobId, Boolean allowNonRestoredState, String savepointPath, RecoveryClaimMode deprecatedRecoveryClaimMode, RecoveryClaimMode recoveryClaimMode, Map<String,String> flinkConfiguration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Boolean
getAllowNonRestoredState()
RecoveryClaimMode
getRecoveryClaimMode()
String
getSavepointPath()
boolean
isDeprecatedRestoreModeHasValue()
-
Methods inherited from class org.apache.flink.runtime.webmonitor.handlers.JarRequestBody
getEntryClassName, getFlinkConfiguration, getJobId, getParallelism, getProgramArgumentsList
-
-
-
-
Constructor Detail
-
JarRunRequestBody
public JarRunRequestBody()
-
JarRunRequestBody
@VisibleForTesting public JarRunRequestBody(@Nullable String entryClassName, @Nullable List<String> programArgumentsList, @Nullable Integer parallelism, @Nullable JobID jobId, @Nullable Boolean allowNonRestoredState, @Nullable String savepointPath, @Nullable RecoveryClaimMode recoveryClaimMode, @Nullable Map<String,String> flinkConfiguration)
Fallback constructor ONLY for tests.
-
JarRunRequestBody
public JarRunRequestBody(@Nullable String entryClassName, @Nullable List<String> programArgumentsList, @Nullable Integer parallelism, @Nullable JobID jobId, @Nullable Boolean allowNonRestoredState, @Nullable String savepointPath, @Nullable RecoveryClaimMode deprecatedRecoveryClaimMode, @Nullable RecoveryClaimMode recoveryClaimMode, @Nullable Map<String,String> flinkConfiguration)
-
-
Method Detail
-
getAllowNonRestoredState
@Nullable public Boolean getAllowNonRestoredState()
-
getSavepointPath
@Nullable public String getSavepointPath()
-
getRecoveryClaimMode
@Nullable public RecoveryClaimMode getRecoveryClaimMode()
-
isDeprecatedRestoreModeHasValue
public boolean isDeprecatedRestoreModeHasValue()
-
-