Class DelegationTokenReceiverRepository
- java.lang.Object
-
- org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository
-
-
Constructor Summary
Constructors Constructor Description DelegationTokenReceiverRepository(Configuration configuration, PluginManager pluginManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onNewTokensObtained(byte[] containerBytes)
Callback function when new delegation tokens obtained.void
onNewTokensObtained(DelegationTokenContainer container)
Callback function when new delegation tokens obtained.
-
-
-
Constructor Detail
-
DelegationTokenReceiverRepository
public DelegationTokenReceiverRepository(Configuration configuration, @Nullable PluginManager pluginManager)
-
-
Method Detail
-
onNewTokensObtained
public void onNewTokensObtained(byte[] containerBytes) throws Exception
Callback function when new delegation tokens obtained.- Parameters:
containerBytes
- Serialized form of a DelegationTokenContainer. All the available tokens will be forwarded to the appropriateDelegationTokenReceiver
based on service name.- Throws:
Exception
-
onNewTokensObtained
public void onNewTokensObtained(DelegationTokenContainer container) throws Exception
Callback function when new delegation tokens obtained.- Parameters:
container
- Serialized form of delegation tokens stored in DelegationTokenContainer. All the available tokens will be forwarded to the appropriateDelegationTokenReceiver
based on service name.- Throws:
Exception
-
-