Package org.apache.hadoop.yarn.server.resourcemanager.recovery

Class RMStateStoreUtils

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.recovery.RMStateStoreUtils

@Private
@Unstable
public class RMStateStoreUtils
extends Object

Utility methods for RMStateStore and subclasses.

Field Summary

Fields

Modifier and Type	Field	Description
static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
RMStateStoreUtils()

Method Summary

Modifier and Type	Method	Description
static RMDelegationTokenIdentifierData	readRMDelegationTokenIdentifierData(DataInputStream fsIn)	Returns the RM Delegation Token data from the DataInputStream as a RMDelegationTokenIdentifierData.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

public static final org.slf4j.Logger LOG

Constructor Details

RMStateStoreUtils

public RMStateStoreUtils()

Method Details

readRMDelegationTokenIdentifierData

public static RMDelegationTokenIdentifierData readRMDelegationTokenIdentifierData(DataInputStream fsIn)
                                                                           throws IOException

Returns the RM Delegation Token data from the DataInputStream as a RMDelegationTokenIdentifierData. It can handle both the current and old (non-protobuf) formats.

Parameters:

fsIn - The DataInputStream containing RM Delegation Token data

Returns:

An RMDelegationTokenIdentifierData containing the read in RM Delegation Token

Throws:

IOException - an I/O exception has occurred.