public class JarRunRequestBody extends JarRequestBody
RequestBody
for running a jar.Constructor and Description |
---|
JarRunRequestBody() |
JarRunRequestBody(String entryClassName,
String programArguments,
List<String> programArgumentsList,
Integer parallelism,
JobID jobId,
Boolean allowNonRestoredState,
String savepointPath,
RestoreMode restoreMode,
Map<String,String> flinkConfiguration)
Fallback constructor ONLY for tests.
|
JarRunRequestBody(String entryClassName,
String programArguments,
List<String> programArgumentsList,
Integer parallelism,
JobID jobId,
Boolean allowNonRestoredState,
String savepointPath,
RestoreMode deprecatedRestoreMode,
RestoreMode restoreMode,
Map<String,String> flinkConfiguration) |
Modifier and Type | Method and Description |
---|---|
Boolean |
getAllowNonRestoredState() |
RestoreMode |
getRestoreMode() |
String |
getSavepointPath() |
boolean |
isDeprecatedRestoreModeHasValue() |
getEntryClassName, getFlinkConfiguration, getJobId, getParallelism, getProgramArguments, getProgramArgumentsList
public JarRunRequestBody()
@VisibleForTesting public JarRunRequestBody(@Nullable String entryClassName, @Nullable String programArguments, @Nullable List<String> programArgumentsList, @Nullable Integer parallelism, @Nullable JobID jobId, @Nullable Boolean allowNonRestoredState, @Nullable String savepointPath, @Nullable RestoreMode restoreMode, @Nullable Map<String,String> flinkConfiguration)
public JarRunRequestBody(@Nullable String entryClassName, @Nullable String programArguments, @Nullable List<String> programArgumentsList, @Nullable Integer parallelism, @Nullable JobID jobId, @Nullable Boolean allowNonRestoredState, @Nullable String savepointPath, @Nullable RestoreMode deprecatedRestoreMode, @Nullable RestoreMode restoreMode, @Nullable Map<String,String> flinkConfiguration)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.