org.apache.flink.yarn

Class YarnTaskManagerRunnerFactory

java.lang.Object

org.apache.flink.yarn.YarnTaskManagerRunnerFactory

public class YarnTaskManagerRunnerFactory
extends Object

The entry point for running a TaskManager in a YARN container.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	YarnTaskManagerRunnerFactory.Runner Runner for the YarnTaskManager.

Constructor Summary

Constructors

Constructor and Description
YarnTaskManagerRunnerFactory()

Method Summary

Modifier and Type	Method and Description
static YarnTaskManagerRunnerFactory.Runner	create(String[] args, Class<? extends org.apache.flink.yarn.YarnTaskManager> taskManager, Map<String,String> envs) Creates a YarnTaskManagerRunnerFactory.Runner.

Methods inherited from class java.lang.Object

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

Constructor Detail

YarnTaskManagerRunnerFactory

public YarnTaskManagerRunnerFactory()

Method Detail

create

public static YarnTaskManagerRunnerFactory.Runner create(String[] args,
                                                         Class<? extends org.apache.flink.yarn.YarnTaskManager> taskManager,
                                                         Map<String,String> envs)
                                                  throws IOException

Creates a YarnTaskManagerRunnerFactory.Runner.

Throws:

IOException