Package org.apache.hadoop.yarn.ipc

Class YarnRPC

java.lang.Object
org.apache.hadoop.yarn.ipc.YarnRPC
Direct Known Subclasses:
HadoopYarnProtoRPC
@LimitedPrivate({"MapReduce","YARN"}) public abstract class YarnRPC extends Object
Abstraction to get the RPC implementation for Yarn.

  • Constructor Summary

    Constructors
    Constructor
    Description
    YarnRPC()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static YarnRPC
    create(org.apache.hadoop.conf.Configuration conf)
     
    abstract Object
    getProxy(Class protocol, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf)
     
    org.apache.hadoop.ipc.Server
    getServer(Class protocol, Object instance, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager, int numHandlers)
     
    abstract org.apache.hadoop.ipc.Server
    getServer(Class protocol, Object instance, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager, int numHandlers, String portRangeConfig)
     
    abstract void
    stopProxy(Object proxy, org.apache.hadoop.conf.Configuration conf)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • YarnRPC

      public YarnRPC()

  • Method Details

    • getProxy

      public abstract Object getProxy(Class protocol, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf)

    • stopProxy

      public abstract void stopProxy(Object proxy, org.apache.hadoop.conf.Configuration conf)

    • getServer

      public abstract org.apache.hadoop.ipc.Server getServer(Class protocol, Object instance, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager, int numHandlers, String portRangeConfig)

    • getServer

      public org.apache.hadoop.ipc.Server getServer(Class protocol, Object instance, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager, int numHandlers)

    • create

      public static YarnRPC create(org.apache.hadoop.conf.Configuration conf)