@InterfaceAudience.Private
public class HSAdminServer
extends org.apache.hadoop.service.AbstractService
implements org.apache.hadoop.mapreduce.v2.api.HSAdminProtocol
Modifier and Type | Field and Description |
---|---|
protected InetSocketAddress |
clientRpcAddress |
protected org.apache.hadoop.ipc.RPC.Server |
clientRpcServer
The RPC server that listens to requests from clients
|
Constructor and Description |
---|
HSAdminServer(org.apache.hadoop.yarn.logaggregation.AggregatedLogDeletionService aggLogDelService,
JobHistory jobHistoryService) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.conf.Configuration |
createConf() |
String[] |
getGroupsForUser(String user) |
void |
refreshAdminAcls() |
void |
refreshJobRetentionSettings() |
void |
refreshLoadedJobCache() |
void |
refreshLogRetentionSettings() |
void |
refreshSuperUserGroupsConfiguration() |
void |
refreshUserToGroupsMappings() |
void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
protected void |
serviceStop() |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
protected org.apache.hadoop.ipc.RPC.Server clientRpcServer
protected InetSocketAddress clientRpcAddress
public HSAdminServer(org.apache.hadoop.yarn.logaggregation.AggregatedLogDeletionService aggLogDelService, JobHistory jobHistoryService)
public void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
public String[] getGroupsForUser(String user) throws IOException
getGroupsForUser
in interface org.apache.hadoop.tools.GetUserMappingsProtocol
IOException
public void refreshUserToGroupsMappings() throws IOException
refreshUserToGroupsMappings
in interface org.apache.hadoop.security.RefreshUserMappingsProtocol
IOException
public void refreshSuperUserGroupsConfiguration() throws IOException
refreshSuperUserGroupsConfiguration
in interface org.apache.hadoop.security.RefreshUserMappingsProtocol
IOException
protected org.apache.hadoop.conf.Configuration createConf()
public void refreshAdminAcls() throws IOException
refreshAdminAcls
in interface org.apache.hadoop.mapreduce.v2.api.HSAdminRefreshProtocol
IOException
public void refreshLoadedJobCache() throws IOException
refreshLoadedJobCache
in interface org.apache.hadoop.mapreduce.v2.api.HSAdminRefreshProtocol
IOException
public void refreshLogRetentionSettings() throws IOException
refreshLogRetentionSettings
in interface org.apache.hadoop.mapreduce.v2.api.HSAdminRefreshProtocol
IOException
public void refreshJobRetentionSettings() throws IOException
refreshJobRetentionSettings
in interface org.apache.hadoop.mapreduce.v2.api.HSAdminRefreshProtocol
IOException
Copyright © 2017 Apache Software Foundation. All Rights Reserved.