public class YarnTaskManagerRunnerFactory extends Object
Modifier and Type | Class and Description |
---|---|
static class |
YarnTaskManagerRunnerFactory.Runner
Runner for the
YarnTaskManager . |
Constructor and Description |
---|
YarnTaskManagerRunnerFactory() |
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 . |
public static YarnTaskManagerRunnerFactory.Runner create(String[] args, Class<? extends org.apache.flink.yarn.YarnTaskManager> taskManager, Map<String,String> envs) throws IOException
YarnTaskManagerRunnerFactory.Runner
.IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.