org.springframework.yarn.support
Class YarnUtils

java.lang.Object
  extended by org.springframework.yarn.support.YarnUtils

public class YarnUtils
extends Object

Different utilities.

Author:
Janne Valkealahti

Constructor Summary
YarnUtils()
           
 
Method Summary
static DataAccessException convertYarnAccessException(IOException e)
          Converts IOException to a Spring dao exception.
static DataAccessException convertYarnAccessException(org.apache.hadoop.ipc.RemoteException e)
          Converts RemoteException to a Spring dao exception.
static DataAccessException convertYarnAccessException(YarnException e)
          Converts YarnException to a Spring dao exception.
static DataAccessException convertYarnAccessException(YarnRuntimeException e)
          Converts YarnRuntimeException to a Spring dao exception.
static InetSocketAddress getAddress(Configuration conf)
          Gets the address.
static ApplicationAttemptId getApplicationAttemptId(Map<String,String> environment)
          Gets ApplicationAttemptId from environment variables.
static String getPrincipal(Configuration conf)
          Gets the principal.
static String getUserName(Configuration conf)
          Gets the user name.
static Configuration merge(Configuration base, Configuration merge)
          Merge configurations together.
static String toString(Configuration conf)
          Better toString() for hadoop Configuration.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

YarnUtils

public YarnUtils()
Method Detail

convertYarnAccessException

public static DataAccessException convertYarnAccessException(YarnRuntimeException e)
Converts YarnRuntimeException to a Spring dao exception.

Parameters:
e - the YarnRuntimeException
Returns:
a wrapped native exception into DataAccessException

convertYarnAccessException

public static DataAccessException convertYarnAccessException(IOException e)
Converts IOException to a Spring dao exception.

Parameters:
e - the IOException
Returns:
a wrapped native exception into DataAccessException

convertYarnAccessException

public static DataAccessException convertYarnAccessException(org.apache.hadoop.ipc.RemoteException e)
Converts RemoteException to a Spring dao exception.

Parameters:
e - the RemoteException
Returns:
a wrapped native exception into DataAccessException

convertYarnAccessException

public static DataAccessException convertYarnAccessException(YarnException e)
Converts YarnException to a Spring dao exception.

Parameters:
e - the YarnException
Returns:
a wrapped native exception into DataAccessException

getApplicationAttemptId

public static ApplicationAttemptId getApplicationAttemptId(Map<String,String> environment)
Gets ApplicationAttemptId from environment variables.

Parameters:
environment - Map of environment variables
Returns:
the ApplicationAttemptId

getPrincipal

public static String getPrincipal(Configuration conf)
                           throws IOException
Gets the principal.

Parameters:
conf - the conf
Returns:
the principal
Throws:
IOException - Signals that an I/O exception has occurred.

getUserName

public static String getUserName(Configuration conf)
Gets the user name.

Parameters:
conf - the Yarn configuration
Returns:
the user name

getAddress

public static InetSocketAddress getAddress(Configuration conf)
Gets the address.

Parameters:
conf - the Yarn configuration
Returns:
the address

merge

public static Configuration merge(Configuration base,
                                  Configuration merge)
Merge configurations together.

Parameters:
base - the configuration to merge to
merge - the configuration to merge
Returns:
the merged configuration

toString

public static String toString(Configuration conf)
Better toString() for hadoop Configuration.

Parameters:
conf - the configuration
Returns:
the string representation of a configuration