Package org.apache.hadoop.yarn.server.sharedcachemanager

Class SharedCacheUploaderService

java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.server.sharedcachemanager.SharedCacheUploaderService
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.service.Service, org.apache.hadoop.yarn.server.api.SCMUploaderProtocol
public class SharedCacheUploaderService extends org.apache.hadoop.service.AbstractService implements org.apache.hadoop.yarn.server.api.SCMUploaderProtocol
This service handles all rpc calls from the NodeManager uploader to the shared cache manager.

  • 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
    SharedCacheUploaderService(SCMStore store)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadResponse
    canUpload(org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadRequest request)
     
    org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyResponse
    notify(org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyRequest request)
     
    protected void
    serviceInit(org.apache.hadoop.conf.Configuration conf)
     
    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, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • SharedCacheUploaderService

      public SharedCacheUploaderService(SCMStore store)

  • Method Details

    • serviceInit

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

    • 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

    • notify

      public org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyResponse notify(org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderNotifyRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      notify in interface org.apache.hadoop.yarn.server.api.SCMUploaderProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException

    • canUpload

      public org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadResponse canUpload(org.apache.hadoop.yarn.server.api.protocolrecords.SCMUploaderCanUploadRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
      Specified by:
      canUpload in interface org.apache.hadoop.yarn.server.api.SCMUploaderProtocol
      Throws:
      org.apache.hadoop.yarn.exceptions.YarnException
      IOException