@Test public void testGetSessionToken() throws IOException { TestingTools.startServer(new FakeServer(fakeKDC), grpcCleanup); Configuration conf = TestingTools.getBrokerConfig(); Subject alice = fakeKDC.login(ALICE); UserGroupInformation.loginUserFromSubject(alice); String token = getSessionToken(conf); assertEquals("FakeSessionToken/AuthenticatedUser=" + ALICE + ";Owner=" + ALICE + ";Target=" + MOCK_BUCKET, token); UserGroupInformation.setLoginUser(null); }
public String getSessionToken(){ return sessionToken; }
BrokerTokenIdentifier extends DelegationTokenIdentifier { public String getSessionToken(){ return sessionToken; } }
BrokerTokenIdentifier extends DelegationTokenIdentifier { public String getSessionToken(){ return sessionToken; } BrokerTokenIdentifier();  BrokerTokenIdentifier(Configuration config, Text owner, Text renewer, Text realUser, Text service); }
BrokerTokenIdentifier extends DelegationTokenIdentifier { public String getSessionToken(){ return sessionToken; } BrokerTokenIdentifier();  BrokerTokenIdentifier(Configuration config, Text owner, Text renewer, Text realUser, Text service); @Override void write(DataOutput out); @Override void readFields(DataInput in); void setSessionToken(String sessionToken); String getSessionToken(); }
BrokerTokenIdentifier extends DelegationTokenIdentifier { public String getSessionToken(){ return sessionToken; } BrokerTokenIdentifier();  BrokerTokenIdentifier(Configuration config, Text owner, Text renewer, Text realUser, Text service); @Override void write(DataOutput out); @Override void readFields(DataInput in); void setSessionToken(String sessionToken); String getSessionToken(); static final Text KIND; }