public class TimelineConnector
extends org.apache.hadoop.service.AbstractService
Modifier and Type | Class and Description |
---|---|
static class |
TimelineConnector.TimelineClientRetryOp
Abstract class for an operation that should be retried by timeline client.
|
static class |
TimelineConnector.TimelineClientRetryOpForOperateDelegationToken |
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_SOCKET_TIMEOUT |
Constructor and Description |
---|
TimelineConnector(boolean requireConnectionRetry,
org.apache.hadoop.security.UserGroupInformation authUgi,
String doAsUser,
org.apache.hadoop.security.token.delegation.web.DelegationTokenAuthenticatedURL.Token token) |
Modifier and Type | Method and Description |
---|---|
static URI |
constructResURI(org.apache.hadoop.conf.Configuration conf,
String address,
String uri) |
com.sun.jersey.api.client.Client |
getClient() |
protected org.apache.hadoop.security.ssl.SSLFactory |
getSSLFactory(org.apache.hadoop.conf.Configuration conf) |
Object |
operateDelegationToken(PrivilegedExceptionAction<?> action) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStop() |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceStart, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public static final int DEFAULT_SOCKET_TIMEOUT
public TimelineConnector(boolean requireConnectionRetry, org.apache.hadoop.security.UserGroupInformation authUgi, String doAsUser, org.apache.hadoop.security.token.delegation.web.DelegationTokenAuthenticatedURL.Token token)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected org.apache.hadoop.security.ssl.SSLFactory getSSLFactory(org.apache.hadoop.conf.Configuration conf) throws GeneralSecurityException, IOException
GeneralSecurityException
IOException
public static URI constructResURI(org.apache.hadoop.conf.Configuration conf, String address, String uri)
protected void serviceStop()
serviceStop
in class org.apache.hadoop.service.AbstractService
public com.sun.jersey.api.client.Client getClient()
public Object operateDelegationToken(PrivilegedExceptionAction<?> action) throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
IOException
org.apache.hadoop.yarn.exceptions.YarnException
Copyright © 2008–2022 Apache Software Foundation. All rights reserved.