public class ContaineredTaskManagerParameters extends Object implements Serializable
Constructor and Description |
---|
ContaineredTaskManagerParameters(long totalContainerMemoryMB,
long taskManagerHeapSizeMB,
long taskManagerDirectMemoryLimitMB,
int numSlots,
HashMap<String,String> taskManagerEnv) |
Modifier and Type | Method and Description |
---|---|
static ContaineredTaskManagerParameters |
create(Configuration config,
long containerMemoryMB,
int numSlots)
Computes the parameters to be used to start a TaskManager Java process.
|
int |
numSlots() |
long |
taskManagerDirectMemoryLimitMB() |
Map<String,String> |
taskManagerEnv() |
long |
taskManagerHeapSizeMB() |
long |
taskManagerTotalMemoryMB() |
String |
toString() |
public long taskManagerTotalMemoryMB()
public long taskManagerHeapSizeMB()
public long taskManagerDirectMemoryLimitMB()
public int numSlots()
public static ContaineredTaskManagerParameters create(Configuration config, long containerMemoryMB, int numSlots)
config
- The Flink configuration.containerMemoryMB
- The size of the complete container, in megabytes.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.