Package org.apache.hadoop.mapreduce.v2.app.client

Class MRClientService

java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.mapreduce.v2.app.client.MRClientService
All Implemented Interfaces:
Closeable, AutoCloseable, ClientService, org.apache.hadoop.service.Service
public class MRClientService extends org.apache.hadoop.service.AbstractService implements ClientService
This module is responsible for talking to the jobclient (user facing).

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

    org.apache.hadoop.service.Service.STATE

  • Constructor Summary

    Constructors
    Constructor
    Description
    MRClientService(AppContext appContext)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.glassfish.jersey.server.ResourceConfig
    configure()
     
    org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillTaskAttemptResponse
    forceKillTaskAttempt(org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillTaskAttemptRequest request)
     
    InetSocketAddress
    getBindAddress()
     
    int
    getHttpPort()
     
    org.apache.hadoop.yarn.webapp.WebApp
    getWebApp()
     
    protected void
    serviceStart()
     
    protected void
    serviceStop()
     

    Methods inherited from class org.apache.hadoop.service.AbstractService

    close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.hadoop.service.Service

    close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, registerServiceListener, start, stop, unregisterServiceListener, waitForServiceToStop

  • Constructor Details

    • MRClientService

      public MRClientService(AppContext appContext)

  • Method Details

    • serviceStart

      protected void serviceStart() throws Exception
      Overrides:
      serviceStart in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • serviceStop

      protected void serviceStop() throws Exception
      Overrides:
      serviceStop in class org.apache.hadoop.service.AbstractService
      Throws:
      Exception

    • getBindAddress

      public InetSocketAddress getBindAddress()
      Specified by:
      getBindAddress in interface ClientService

    • getHttpPort

      public int getHttpPort()
      Specified by:
      getHttpPort in interface ClientService

    • forceKillTaskAttempt

      public org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillTaskAttemptResponse forceKillTaskAttempt(org.apache.hadoop.mapreduce.v2.api.protocolrecords.KillTaskAttemptRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • getWebApp

      public org.apache.hadoop.yarn.webapp.WebApp getWebApp()

    • configure

      protected org.glassfish.jersey.server.ResourceConfig configure()