Class JobLauncher


  • public final class JobLauncher
    extends Object
    Job launcher.
    • Method Detail

      • main

        public static void main​(String[] args)
                         throws Exception
        Main JobLauncher method.
        Parameters:
        args - arguments.
        Throws:
        Exception - exception on the way.
      • shutdown

        public static void shutdown()
      • launchDAG

        public static void launchDAG​(IRDAG dag)
        Launch application using the application DAG. Notice that we launch the DAG one at a time, as the result of a DAG has to be immediately returned to the Java variable before the application can be resumed.
        Parameters:
        dag - the application DAG.
      • launchDAG

        public static void launchDAG​(IRDAG dag,
                                     String jobId)
        Parameters:
        dag - the application DAG.
        jobId - job ID.
      • launchDAG

        public static void launchDAG​(IRDAG dag,
                                     Map<Serializable,​Object> broadcastVariables,
                                     String jobId)
        Parameters:
        dag - the application DAG.
        broadcastVariables - broadcast variables (can be empty).
        jobId - job ID.
      • getJobConf

        public static org.apache.reef.tang.Configuration getJobConf​(String[] args)
                                                             throws IOException
        Get job configuration.
        Parameters:
        args - arguments to be processed as command line.
        Returns:
        job configuration.
        Throws:
        IOException - exception while processing command line.
      • getBuiltJobConf

        public static org.apache.reef.tang.Configuration getBuiltJobConf()
        Get the built job configuration. It can be null if this method is not called by the process which called the main function of this class.
        Returns:
        the built job configuration.
      • getCollectedData

        public static <T> List<T> getCollectedData()
        Get the collected data.
        Type Parameters:
        T - the type of the data.
        Returns:
        the collected data.