本文整理汇总了Java中org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager类的典型用法代码示例。如果您正苦于以下问题：Java RMDelegationTokenSecretManager类的具体用法？Java RMDelegationTokenSecretManager怎么用？Java RMDelegationTokenSecretManager使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RMDelegationTokenSecretManager类属于org.apache.hadoop.yarn.server.resourcemanager.security包，在下文中一共展示了RMDelegationTokenSecretManager类的12个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: createRMDelegationTokenSecretManager
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
@VisibleForTesting
protected RMDelegationTokenSecretManager createRMDelegationTokenSecretManager(
Configuration conf, RMContext rmContext) {
long secretKeyInterval =
conf.getLong(YarnConfiguration.RM_DELEGATION_KEY_UPDATE_INTERVAL_KEY,
YarnConfiguration.RM_DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT);
long tokenMaxLifetime =
conf.getLong(YarnConfiguration.RM_DELEGATION_TOKEN_MAX_LIFETIME_KEY,
YarnConfiguration.RM_DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT);
long tokenRenewInterval =
conf.getLong(YarnConfiguration.RM_DELEGATION_TOKEN_RENEW_INTERVAL_KEY,
YarnConfiguration.RM_DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT);
return new RMDelegationTokenSecretManager(secretKeyInterval,
tokenMaxLifetime, tokenRenewInterval, 3600000, rmContext);
}
开发者ID:naver，项目名称:hadoop，代码行数:17，代码来源:RMSecretManagerService.java
示例2: createRMDelegationTokenSecretManager
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
private static RMDelegationTokenSecretManager
createRMDelegationTokenSecretManager(long secretKeyInterval,
long tokenMaxLifetime, long tokenRenewInterval) {
RMContext rmContext = mock(RMContext.class);
when(rmContext.getStateStore()).thenReturn(new NullRMStateStore());
RMDelegationTokenSecretManager rmDtSecretManager =
new RMDelegationTokenSecretManager(secretKeyInterval, tokenMaxLifetime,
tokenRenewInterval, 3600000, rmContext);
return rmDtSecretManager;
}
开发者ID:naver，项目名称:hadoop，代码行数:12，代码来源:TestClientRMTokens.java
示例3: createRMDelegationTokenSecretManager
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
@VisibleForTesting
protected RMDelegationTokenSecretManager createRMDelegationTokenSecretManager(
Configuration conf, RMContext rmContext) {
long secretKeyInterval =
conf.getLong(YarnConfiguration.DELEGATION_KEY_UPDATE_INTERVAL_KEY,
YarnConfiguration.DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT);
long tokenMaxLifetime =
conf.getLong(YarnConfiguration.DELEGATION_TOKEN_MAX_LIFETIME_KEY,
YarnConfiguration.DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT);
long tokenRenewInterval =
conf.getLong(YarnConfiguration.DELEGATION_TOKEN_RENEW_INTERVAL_KEY,
YarnConfiguration.DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT);
return new RMDelegationTokenSecretManager(secretKeyInterval,
tokenMaxLifetime, tokenRenewInterval, 3600000, rmContext);
}
开发者ID:Nextzero，项目名称:hadoop-2.6.0-cdh5.4.3，代码行数:17，代码来源:RMSecretManagerService.java
示例4: generateRMContext
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
private RMContext generateRMContext(AbstractYarnScheduler<FiCaSchedulerApp, FiCaSchedulerNode> scheduler) throws Exception {
Configuration conf = new Configuration();
MockRMContext context = null;
Dispatcher dispatcher = new MockDispatcher();
RMApplicationHistoryWriter rmApplicationHistoryWriter = new RMApplicationHistoryWriter();
AMLivelinessMonitor amLivelinessMonitor = new AMLivelinessMonitor(dispatcher);
AMLivelinessMonitor amFinishingMonitor = new AMLivelinessMonitor(dispatcher);
RMDelegationTokenSecretManager delegationTokenSecretManager = new RMDelegationTokenSecretManager(1, 1, 1, 1, context);
context = new MockRMContext();
context.setStateStore(TestObjectFactory.getStateStore(conf, "tmp/myriad-operations-test"));
context.setAmLivelinessMonitor(amLivelinessMonitor);
context.setAmFinishingMonitor(amFinishingMonitor);
context.setRMApplicationHistoryWriter(rmApplicationHistoryWriter);
context.setRMDelegationTokenSecretManager(delegationTokenSecretManager);
return context;
}
开发者ID:apache，项目名称:incubator-myriad，代码行数:19，代码来源:MyriadOperationsTest.java
示例5: ClientRMService
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
public ClientRMService(RMContext rmContext, YarnScheduler scheduler,
RMAppManager rmAppManager, ApplicationACLsManager applicationACLsManager,
QueueACLsManager queueACLsManager,
RMDelegationTokenSecretManager rmDTSecretManager) {
this(rmContext, scheduler, rmAppManager, applicationACLsManager,
queueACLsManager, rmDTSecretManager, new UTCClock());
}
开发者ID:naver，项目名称:hadoop，代码行数:8，代码来源:ClientRMService.java
示例6: ClientRMServiceForTest
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
public ClientRMServiceForTest(Configuration conf,
ResourceScheduler scheduler,
RMDelegationTokenSecretManager rmDTSecretManager) {
super(mock(RMContext.class), scheduler, mock(RMAppManager.class),
new ApplicationACLsManager(conf), new QueueACLsManager(scheduler,
conf), rmDTSecretManager);
}
开发者ID:naver，项目名称:hadoop，代码行数:8，代码来源:TestClientRMTokens.java
示例7: MyClientRMService
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
public MyClientRMService(RMContext rmContext, YarnScheduler scheduler,
RMAppManager rmAppManager,
ApplicationACLsManager applicationACLsManager,
QueueACLsManager queueACLsManager,
RMDelegationTokenSecretManager rmDTSecretManager) {
super(rmContext, scheduler, rmAppManager, applicationACLsManager,
queueACLsManager, rmDTSecretManager);
this.rmContext = rmContext;
}
开发者ID:naver，项目名称:hadoop，代码行数:10，代码来源:TestKillApplicationWithRMHA.java
示例8: setupSecretManager
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
@BeforeClass
public static void setupSecretManager() throws IOException {
RMContext rmContext = mock(RMContext.class);
when(rmContext.getStateStore()).thenReturn(new NullRMStateStore());
dtsm = new RMDelegationTokenSecretManager(60000, 60000, 60000, 60000, rmContext);
dtsm.startThreads();
}
开发者ID:naver，项目名称:hadoop，代码行数:8，代码来源:TestClientRMService.java
示例9: CustomedClientRMService
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
public CustomedClientRMService(RMContext rmContext,
YarnScheduler scheduler, RMAppManager rmAppManager,
ApplicationACLsManager applicationACLsManager,
QueueACLsManager queueACLsManager,
RMDelegationTokenSecretManager rmDTSecretManager) {
super(rmContext, scheduler, rmAppManager, applicationACLsManager,
queueACLsManager, rmDTSecretManager);
}
开发者ID:naver，项目名称:hadoop，代码行数:9，代码来源:ProtocolHATestBase.java
示例10: setupSecretManager
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
@BeforeClass
public static void setupSecretManager() throws IOException {
RMContext rmContext = mock(RMContext.class);
when(rmContext.getStateStore()).thenReturn(new NullRMStateStore());
dtsm =
new RMDelegationTokenSecretManager(60000, 60000, 60000, 60000,
rmContext);
dtsm.startThreads();
Configuration conf = new Configuration();
conf.set("hadoop.security.authentication", "kerberos");
conf.set("hadoop.security.auth_to_local", kerberosRule);
UserGroupInformation.setConfiguration(conf);
}
开发者ID:aliyun-beta，项目名称:aliyun-oss-hadoop-fs，代码行数:14，代码来源:TestTokenClientRMService.java
示例11: createRMDelegationTokenSecretManager
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
protected RMDelegationTokenSecretManager
createRMDelegationTokenSecretManager(RMContext rmContext) {
long secretKeyInterval =
conf.getLong(YarnConfiguration.DELEGATION_KEY_UPDATE_INTERVAL_KEY,
YarnConfiguration.DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT);
long tokenMaxLifetime =
conf.getLong(YarnConfiguration.DELEGATION_TOKEN_MAX_LIFETIME_KEY,
YarnConfiguration.DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT);
long tokenRenewInterval =
conf.getLong(YarnConfiguration.DELEGATION_TOKEN_RENEW_INTERVAL_KEY,
YarnConfiguration.DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT);
return new RMDelegationTokenSecretManager(secretKeyInterval,
tokenMaxLifetime, tokenRenewInterval, 3600000, rmContext);
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:16，代码来源:ResourceManager.java
示例12: ClientRMService
import org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager; //导入依赖的package包/类
public ClientRMService(RMContext rmContext, YarnScheduler scheduler,
RMAppManager rmAppManager, ApplicationACLsManager applicationACLsManager,
RMDelegationTokenSecretManager rmDTSecretManager) {
super(ClientRMService.class.getName());
this.scheduler = scheduler;
this.rmContext = rmContext;
this.rmAppManager = rmAppManager;
this.applicationsACLsManager = applicationACLsManager;
this.rmDTSecretManager = rmDTSecretManager;
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:11，代码来源:ClientRMService.java
注：本文中的org.apache.hadoop.yarn.server.resourcemanager.security.RMDelegationTokenSecretManager类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论