public class ContaineredTaskManagerParameters extends Object implements Serializable
Constructor and Description |
---|
ContaineredTaskManagerParameters(TaskExecutorProcessSpec taskExecutorProcessSpec,
HashMap<String,String> taskManagerEnv) |
Modifier and Type | Method and Description |
---|---|
static ContaineredTaskManagerParameters |
create(Configuration config,
TaskExecutorProcessSpec taskExecutorProcessSpec)
Computes the parameters to be used to start a TaskManager Java process.
|
TaskExecutorProcessSpec |
getTaskExecutorProcessSpec() |
Map<String,String> |
taskManagerEnv() |
String |
toString() |
public ContaineredTaskManagerParameters(TaskExecutorProcessSpec taskExecutorProcessSpec, HashMap<String,String> taskManagerEnv)
public TaskExecutorProcessSpec getTaskExecutorProcessSpec()
public static ContaineredTaskManagerParameters create(Configuration config, TaskExecutorProcessSpec taskExecutorProcessSpec)
config
- The Flink configuration.taskExecutorProcessSpec
- The resource specifics of the task executor.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.