Module ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad Num Num body Assign TupleStore AttributeStore NameLoad attr AttributeStore NameLoad attr AttributeStore NameLoad attr TupleLoad NameLoad NameLoad NameLoad If CompareIs NameLoad NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign TupleStore NameStore NameStore Call NameLoad Assign TupleStore AttributeStore NameLoad attr AttributeStore NameLoad attr TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Str Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad body Expr Str Assign NameStore Str Assign NameStore Call NameLoad ListComp NameLoad comprehension TupleStore NameStore NameStore NameLoad If BoolOpAnd CompareIsNot NameLoad NameLoad CompareNotIn NameLoad NameLoad body Assign NameStore BinOpMod Str TupleLoad NameLoad Raise Call NameLoad NameLoad Assign NameStore TupleLoad TupleLoad Str NameLoad TupleLoad Str NameLoad TupleLoad Str NameLoad TupleLoad Str NameLoad TupleLoad Str NameLoad TupleLoad Str NameLoad TupleLoad Str NameLoad TupleLoad Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad Return Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad Assign NameStore ListLoad Str Str If BoolOpAnd CompareIsNot NameLoad NameLoad CompareNotIn NameLoad NameLoad body Assign NameStore BinOpMod Str TupleLoad NameLoad Raise Call NameLoad NameLoad Assign NameStore Dict If CompareIsNot NameLoad NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Return Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad keyword NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad keyword NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad keyword NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad keyword NameLoad keyword NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr keyword NameLoad keyword NameLoad keyword NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list
N/A __future__ unicode_literals base BaseYarnAPI constants JobStateInternal errors IllegalArgumentError hadoop_conf get_jobhistory_host_port HistoryServer N/A BaseYarnAPI N/A N/A 
    The history server REST API's allow the user to get status on finished
    applications. Currently it only supports MapReduce and provides
    information on finished jobs.

    If `address` argument is `None` client will try to extract `address` and
    `port` from Hadoop configuration files.

    :param str address: HistoryServer HTTP address
    :param int port: HistoryServer HTTP port
    :param int timeout: API connection timeout in seconds
     __init__ N/A N/A self address port timeout N/A None 19888 30 N/A N/A N/A N/A self address N/A self port N/A self timeout N/A address port timeout N/A N/A address None N/A N/A N/A N/A N/A self logger debug Get information from hadoop conf dir N/A N/A address port N/A get_jobhistory_host_port N/A N/A N/A self address N/A self port N/A address port N/A application_information N/A N/A self N/A N/A N/A 
        The history server information resource provides overall information
        about the history server.

        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path /ws/v1/history/info N/A N/A N/A self request path N/A jobs N/A N/A self state user queue limit started_time_begin started_time_end finished_time_begin finished_time_end N/A None None None None None None None None N/A N/A 
        The jobs resource provides a list of the MapReduce jobs that have
        finished. It does not currently return a full list of parameters.

        :param str user: user name
        :param str state: the job state
        :param str queue: queue name
        :param str limit: total number of app objects to be returned
        :param str started_time_begin: jobs with start time beginning with
            this time, specified in ms since epoch
        :param str started_time_end: jobs with start time ending with this
            time, specified in ms since epoch
        :param str finished_time_begin: jobs with finish time beginning with
            this time, specified in ms since epoch
        :param str finished_time_end: jobs with finish time ending with this
            time, specified in ms since epoch
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
        :raises yarn_api_client.errors.IllegalArgumentError: if `state`
            incorrect
         N/A path /ws/v1/history/mapreduce/jobs N/A legal_states N/A set N/A s N/A N/A s _ JobStateInternal N/A N/A N/A state None N/A state legal_states N/A N/A msg N/A Job Internal State %s is illegal N/A state N/A N/A IllegalArgumentError msg N/A loc_args N/A N/A state state N/A user user N/A queue queue N/A limit limit N/A startedTimeBegin started_time_begin N/A startedTimeEnd started_time_end N/A finishedTimeBegin finished_time_begin N/A finishedTimeEnd finished_time_end N/A params N/A N/A self construct_parameters loc_args N/A N/A N/A self request path params N/A job N/A N/A self job_id N/A N/A N/A 
        A Job resource contains information about a particular job identified
        by jobid.

        :param str job_id: The job id
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid} format jobid job_id N/A N/A N/A self request path N/A job_attempts N/A N/A self job_id N/A N/A N/A 
        With the job attempts API, you can obtain a collection of resources
        that represent a job attempt.
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid}/jobattempts format jobid job_id N/A N/A N/A self request path N/A job_counters N/A N/A self job_id N/A N/A N/A 
        With the job counters API, you can object a collection of resources
        that represent al the counters for that job.

        :param str job_id: The job id
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid}/counters format jobid job_id N/A N/A N/A self request path N/A job_conf N/A N/A self job_id N/A N/A N/A 
        A job configuration resource contains information about the job
        configuration for this job.

        :param str job_id: The job id
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid}/conf format jobid job_id N/A N/A N/A self request path N/A job_tasks N/A N/A self job_id type N/A None N/A N/A 
        With the tasks API, you can obtain a collection of resources that
        represent a task within a job.

        :param str job_id: The job id
        :param str type: type of task, valid values are m or r. m for map
            task or r for reduce task
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid}/tasks format jobid job_id N/A valid_types N/A m r N/A N/A N/A type None N/A type valid_types N/A N/A msg N/A Job type %s is illegal N/A type N/A N/A IllegalArgumentError msg N/A params N/A N/A N/A type None N/A N/A N/A params N/A type type N/A N/A N/A self request path params N/A job_task N/A N/A self job_id task_id N/A N/A N/A 
        A Task resource contains information about a particular task
        within a job.

        :param str job_id: The job id
        :param str task_id: The task id
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid}/tasks/{taskid} format jobid job_id taskid task_id N/A N/A N/A self request path N/A task_counters N/A N/A self job_id task_id N/A N/A N/A 
        With the task counters API, you can object a collection of resources
        that represent all the counters for that task.

        :param str job_id: The job id
        :param str task_id: The task id
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid}/tasks/{taskid}/counters format jobid job_id taskid task_id N/A N/A N/A self request path N/A task_attempts N/A N/A self job_id task_id N/A N/A N/A 
        With the task attempts API, you can obtain a collection of resources
        that represent a task attempt within a job.

        :param str job_id: The job id
        :param str task_id: The task id
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid}/tasks/{taskid}/attempts format jobid job_id taskid task_id N/A N/A N/A self request path N/A task_attempt N/A N/A self job_id task_id attempt_id N/A N/A N/A 
        A Task Attempt resource contains information about a particular task
        attempt within a job.

        :param str job_id: The job id
        :param str task_id: The task id
        :param str attempt_id: The attempt id
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid}/tasks/{taskid}/attempt/{attemptid} format jobid job_id taskid task_id attemptid attempt_id N/A N/A N/A self request path N/A task_attempt_counters N/A N/A self job_id task_id attempt_id N/A N/A N/A 
        With the task attempt counters API, you can object a collection of
        resources that represent al the counters for that task attempt.

        :param str job_id: The job id
        :param str task_id: The task id
        :param str attempt_id: The attempt id
        :returns: API response object with JSON data
        :rtype: :py:class:`yarn_api_client.base.Response`
         N/A path N/A N/A /ws/v1/history/mapreduce/jobs/{jobid}/tasks/{taskid}/attempt/{attemptid}/counters format jobid job_id taskid task_id attemptid attempt_id N/A N/A N/A self request path N/A N/A