org.apache.flink.runtime.clusterframework

Class ContaineredTaskManagerParameters

java.lang.Object

org.apache.flink.runtime.clusterframework.ContaineredTaskManagerParameters

All Implemented Interfaces:

Serializable

public class ContaineredTaskManagerParameters
extends Object
implements Serializable

This class describes the basic parameters for launching a TaskManager process.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ContaineredTaskManagerParameters(long totalContainerMemoryMB, long taskManagerHeapSizeMB, long taskManagerDirectMemoryLimitMB, int numSlots, HashMap<String,String> taskManagerEnv)

Method Summary

Modifier and Type	Method and Description
static long	calculateCutoffMB(Configuration config, long containerMemoryMB) Calcuate cutoff memory size used by container, it will throw an IllegalArgumentException if the config is invalid or return the cutoff value if valid.
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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ContaineredTaskManagerParameters

public ContaineredTaskManagerParameters(long totalContainerMemoryMB,
                                        long taskManagerHeapSizeMB,
                                        long taskManagerDirectMemoryLimitMB,
                                        int numSlots,
                                        HashMap<String,String> taskManagerEnv)

Method Detail

taskManagerTotalMemoryMB

public long taskManagerTotalMemoryMB()

taskManagerHeapSizeMB

public long taskManagerHeapSizeMB()

taskManagerDirectMemoryLimitMB

public long taskManagerDirectMemoryLimitMB()

numSlots

public int numSlots()

taskManagerEnv

public Map<String,String> taskManagerEnv()

toString

public String toString()

Overrides:

toString in class Object

calculateCutoffMB

public static long calculateCutoffMB(Configuration config,
                                     long containerMemoryMB)

Calcuate cutoff memory size used by container, it will throw an IllegalArgumentException if the config is invalid or return the cutoff value if valid.

Parameters:

config - The Flink configuration.

containerMemoryMB - The size of the complete container, in megabytes.

Returns:

cutoff memory size used by container.

create

public static ContaineredTaskManagerParameters create(Configuration config,
                                                      long containerMemoryMB,
                                                      int numSlots)

Computes the parameters to be used to start a TaskManager Java process.

Parameters:

config - The Flink configuration.

containerMemoryMB - The size of the complete container, in megabytes.

Returns:

The parameters to start the TaskManager processes with.