Toggle navigation
Home
org.apache.hadoop.security.authentication.client.ConnectionConfigurator to org.apache.hadoop.yarn.client.api.impl.TimelineConnector
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'hadoop'}
Hierarchy/Composition: Composition
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
initConnConfigurator(conf)
to
createTimelineConnector()
constructResURI(getConfig(),getTimelineServiceAddress(),false)
to
TimelineConnector.constructResURI(getConfig(),getTimelineServiceAddress(),RESOURCE_URI_STR_V1)
constructResURI(getConfig(),getTimelineServiceAddress(),false)
to
TimelineConnector.constructResURI(getConfig(),getTimelineServiceAddress(),RESOURCE_URI_STR_V1)
Rename Variable
connConfigurator
to
connector
connConfigurator
to
connector
connConfigurator
to
connector
Update Anonymous class
{ @Override public Long run() throws Exception { if (!timelineDT.equals(token.getDelegationToken())) { token.setDelegationToken((Token)timelineDT); } DelegationTokenAuthenticatedURL authUrl=new DelegationTokenAuthenticatedURL(authenticator,connConfigurator); final URI serviceURI=isTokenServiceAddrEmpty ? constructResURI(getConfig(),getTimelineServiceAddress(),false) : new URI(scheme,null,address.getHostName(),address.getPort(),RESOURCE_URI_STR_V1,null,null); return authUrl.renewDelegationToken(serviceURI.toURL(),token,doAsUser); } }
to
{ @Override public Long run() throws Exception { if (!timelineDT.equals(token.getDelegationToken())) { token.setDelegationToken((Token)timelineDT); } DelegationTokenAuthenticatedURL authUrl=connector.getDelegationTokenAuthenticatedURL(); final URI serviceURI=isTokenServiceAddrEmpty ? TimelineConnector.constructResURI(getConfig(),getTimelineServiceAddress(),RESOURCE_URI_STR_V1) : new URI(scheme,null,address.getHostName(),address.getPort(),RESOURCE_URI_STR_V1,null,null); return authUrl.renewDelegationToken(serviceURI.toURL(),token,doAsUser); } }
{ @Override public Void run() throws Exception { if (!timelineDT.equals(token.getDelegationToken())) { token.setDelegationToken((Token)timelineDT); } DelegationTokenAuthenticatedURL authUrl=new DelegationTokenAuthenticatedURL(authenticator,connConfigurator); final URI serviceURI=isTokenServiceAddrEmpty ? constructResURI(getConfig(),getTimelineServiceAddress(),false) : new URI(scheme,null,address.getHostName(),address.getPort(),RESOURCE_URI_STR_V1,null,null); authUrl.cancelDelegationToken(serviceURI.toURL(),token,doAsUser); return null; } }
to
{ @Override public Void run() throws Exception { if (!timelineDT.equals(token.getDelegationToken())) { token.setDelegationToken((Token)timelineDT); } DelegationTokenAuthenticatedURL authUrl=connector.getDelegationTokenAuthenticatedURL(); final URI serviceURI=isTokenServiceAddrEmpty ? TimelineConnector.constructResURI(getConfig(),getTimelineServiceAddress(),RESOURCE_URI_STR_V1) : new URI(scheme,null,address.getHostName(),address.getPort(),RESOURCE_URI_STR_V1,null,null); authUrl.cancelDelegationToken(serviceURI.toURL(),token,doAsUser); return null; } }