|
@@ -48,6 +48,8 @@ import org.apache.hadoop.security.SaslRpcServer;
|
|
import org.apache.hadoop.security.UserGroupInformation;
|
|
import org.apache.hadoop.security.UserGroupInformation;
|
|
import org.apache.hadoop.security.token.SecretManager;
|
|
import org.apache.hadoop.security.token.SecretManager;
|
|
import org.apache.hadoop.security.token.TokenIdentifier;
|
|
import org.apache.hadoop.security.token.TokenIdentifier;
|
|
|
|
+import org.apache.hadoop.classification.InterfaceAudience;
|
|
|
|
+import org.apache.hadoop.classification.InterfaceStability;
|
|
import org.apache.hadoop.conf.*;
|
|
import org.apache.hadoop.conf.*;
|
|
import org.apache.hadoop.util.ReflectionUtils;
|
|
import org.apache.hadoop.util.ReflectionUtils;
|
|
import org.apache.hadoop.util.Time;
|
|
import org.apache.hadoop.util.Time;
|
|
@@ -72,6 +74,8 @@ import com.google.protobuf.BlockingService;
|
|
* All methods in the protocol should throw only IOException. No field data of
|
|
* All methods in the protocol should throw only IOException. No field data of
|
|
* the protocol instance is transmitted.
|
|
* the protocol instance is transmitted.
|
|
*/
|
|
*/
|
|
|
|
+@InterfaceAudience.LimitedPrivate(value = { "Common", "HDFS", "MapReduce", "Yarn" })
|
|
|
|
+@InterfaceStability.Evolving
|
|
public class RPC {
|
|
public class RPC {
|
|
public enum RpcKind {
|
|
public enum RpcKind {
|
|
RPC_BUILTIN ((short) 1), // Used for built in calls by tests
|
|
RPC_BUILTIN ((short) 1), // Used for built in calls by tests
|