public final class JobLauncher extends Object
Modifier and Type | Method and Description |
---|---|
static org.apache.reef.tang.Configuration |
getDeployModeConf(org.apache.reef.tang.Configuration jobConf)
Get deploy mode configuration.
|
static org.apache.reef.tang.Configuration |
getExecutorResourceConf(org.apache.reef.tang.Configuration jobConf)
Get executor resource configuration.
|
static org.apache.reef.tang.Configuration |
getJobConf(String[] args)
Get job configuration.
|
static void |
launchDAG(DAG dag)
Launch application using the application DAG.
|
static void |
main(String[] args)
Main JobLauncher method.
|
public static void main(String[] args) throws Exception
args
- arguments.Exception
- exception on the way.public static void launchDAG(DAG dag)
dag
- the application DAG.public static org.apache.reef.tang.Configuration getJobConf(String[] args) throws IOException, org.apache.reef.tang.exceptions.InjectionException
args
- arguments to be processed as command line.IOException
- exception while processing command line.org.apache.reef.tang.exceptions.InjectionException
- exception while injection.public static org.apache.reef.tang.Configuration getDeployModeConf(org.apache.reef.tang.Configuration jobConf) throws org.apache.reef.tang.exceptions.InjectionException
jobConf
- job configuration to get deploy mode.org.apache.reef.tang.exceptions.InjectionException
- exception while injection.public static org.apache.reef.tang.Configuration getExecutorResourceConf(org.apache.reef.tang.Configuration jobConf) throws org.apache.reef.tang.exceptions.InjectionException
jobConf
- job configuration to get executor json path.org.apache.reef.tang.exceptions.InjectionException
- exception while injection.Copyright © 2018. All rights reserved.